A B C D E F G H I J K L M N O P R S T V W

A

add(Table) - Method in class com.splout.db.hadoop.TablespaceBuilder
Add a new table to the builder - use a string table identifier for this.
addCascadingTable(Path, String[]) - Method in class com.splout.db.hadoop.TableBuilder
 
addCascadingTable(Path, String[], Configuration) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(Path, char, char, char, boolean, boolean, String, Schema, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(String, char, char, char, boolean, boolean, String, Schema, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(Path, char, char, char, boolean, boolean, String) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(String, char, char, char, boolean, boolean, String) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(Path, Schema, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(String, Schema, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(Path) - Method in class com.splout.db.hadoop.TableBuilder
 
addCSVTextFile(String) - Method in class com.splout.db.hadoop.TableBuilder
 
addCustomInputFormatFile(Path, InputFormat<ITuple, NullWritable>) - Method in class com.splout.db.hadoop.TableBuilder
 
addCustomInputFormatFile(Path, InputFormat<ITuple, NullWritable>, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addCustomInputFormatFile(Path, InputFormat<ITuple, NullWritable>, Map<String, String>, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addFile(TableInput) - Method in class com.splout.db.hadoop.TableBuilder
 
addFixedWidthTextFile(Path, Schema, int[], boolean, String, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
addHiveTable(String, String) - Method in class com.splout.db.hadoop.TableBuilder
 
addHiveTable(String, String, Configuration) - Method in class com.splout.db.hadoop.TableBuilder
 
addSQLite4JavaNativeLibsToDC(Configuration) - Static method in class com.splout.db.common.SploutHadoopConfiguration
Adds the SQLite native libraries to the DistributedCache so that they will be present in the java.library.path of the child's Hadoop task.
addSQLite4JavaNativeLibsToDC(Configuration, File) - Static method in class com.splout.db.common.SploutHadoopConfiguration
Adds the SQLite native libraries to the DistributedCache so that they will be present in the java.library.path of the child's Hadoop task.
addTupleFile(Path) - Method in class com.splout.db.hadoop.TableBuilder
 
addTupleFile(Path, RecordProcessor) - Method in class com.splout.db.hadoop.TableBuilder
 
ALL_PARTITIONS_AVAILABLE - Static variable in class com.splout.db.hadoop.TablespaceBuilder
 

B

BenchmarkStoreTool - Class in com.splout.db.benchmark
Distributed map-only job that creates an arbitrarily big database for being used by BenchmarkTool.
BenchmarkStoreTool() - Constructor for class com.splout.db.benchmark.BenchmarkStoreTool
 
BenchmarkTool - Class in com.splout.db.benchmark
This tool can be used for benchmarking a Splout server.
BenchmarkTool() - Constructor for class com.splout.db.benchmark.BenchmarkTool
 
BenchmarkTool.BenchmarkToolStressThreadImpl - Class in com.splout.db.benchmark
Performs queries like "SELECT * FROM splout_benchmark WHERE key = X;"
BenchmarkTool.BenchmarkToolStressThreadImpl() - Constructor for class com.splout.db.benchmark.BenchmarkTool.BenchmarkToolStressThreadImpl
 
build(Configuration) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
Use this method for obtaining a TablespaceSpec through TablespaceBuilder.
build() - Method in class com.splout.db.hadoop.TableBuilder
 
build() - Method in class com.splout.db.hadoop.TablespaceBuilder
After specifying everything, call this method for building the final tablespace spec.

C

CACHE_FOR - Static variable in class com.splout.db.examples.PageCountsTrendingServlet
 
cancelHeartBeat() - Method in class com.splout.db.common.HeartBeater
inform the background thread that this heartbeat request is not needed.
close() - Method in class com.splout.db.hadoop.JavascriptEngine
 
close(TaskAttemptContext) - Method in class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
close(TaskAttemptContext) - Method in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat.TupleSQLRecordWriter
 
com.splout.db - package com.splout.db
 
com.splout.db.benchmark - package com.splout.db.benchmark
This package contains all the classes related to benchmarking Splout.
com.splout.db.common - package com.splout.db.common
 
com.splout.db.examples - package com.splout.db.examples
 
com.splout.db.hadoop - package com.splout.db.hadoop
This package contains all the classes that implement business logic for helping building Splout datastores using Hadoop with Pangool (http://pangool.net).
com.splout.db.integration - package com.splout.db.integration
 
convert(String) - Method in class com.splout.db.hadoop.SimpleGeneratorCMD.CharConverter
 
CounterInterface - Class in com.splout.db.hadoop
A wrapper around a common functionality used in Hadoop: using Counters.
createIndex(String...) - Method in class com.splout.db.hadoop.TableBuilder
 
createMRBuilder(int, Configuration) - Method in class com.splout.db.hadoop.TablespaceGenerator
Create TupleMRBuilder for launching generation Job.

D

decode(String) - Static method in class com.splout.db.examples.PageCountsRecordProcessor
 
deploy(Collection<TablespaceDepSpec>) - Method in class com.splout.db.hadoop.StoreDeployerTool
Deploy already generated tablespaces at a time.
DeployerCMD - Class in com.splout.db.hadoop
This tool can be used to deploy tablespaces once they are generated.
DeployerCMD() - Constructor for class com.splout.db.hadoop.DeployerCMD
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class com.splout.db.examples.PageCountsServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class com.splout.db.examples.PageCountsTrendingServlet
 
Driver - Class in com.splout.db.hadoop
Hadoop's Driver - add here any Hadoop programs that could be run by default with the Splout JAR.
Driver() - Constructor for class com.splout.db.hadoop.Driver
 

E

execute(String, Object...) - Method in class com.splout.db.hadoop.JavascriptEngine
 
executeViewGeneration(TupleMRBuilder) - Method in class com.splout.db.hadoop.TablespaceGenerator
 

F

finalSQL(String...) - Method in class com.splout.db.hadoop.TableBuilder
 

G

generate(File, int, File) - Method in class com.splout.db.examples.PageCountsDataGenerator
 
generateView(Configuration, TupleSampler.SamplingType, TupleSampler.SamplingOptions) - Method in class com.splout.db.hadoop.TablespaceGenerator
This is the public method which has to be called when using this class as an API.
GeneratorCMD - Class in com.splout.db.hadoop
A general purpose tool for building and deploying any combination of Tablespaces to Splout.
GeneratorCMD() - Constructor for class com.splout.db.hadoop.GeneratorCMD
 
getAverage() - Method in class com.splout.db.benchmark.SploutBenchmark
The average query response time
getAverageRows() - Method in class com.splout.db.benchmark.SploutBenchmark
The average number of rows hit per query
getBatchSize() - Method in class com.splout.db.hadoop.TablespaceGenerator
 
getCascadingColumns() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getConf() - Method in class com.splout.db.benchmark.BenchmarkStoreTool
 
getConf() - Method in class com.splout.db.benchmark.IdentityJob
 
getConf() - Method in class com.splout.db.examples.PageCountsExample
 
getConf() - Method in class com.splout.db.hadoop.DeployerCMD
 
getConf() - Method in class com.splout.db.hadoop.GeneratorCMD
 
getConf() - Method in class com.splout.db.hadoop.SimpleGeneratorCMD
 
getConf() - Method in class com.splout.db.integration.HadoopIntegrationTest
 
getConnectionPool() - Method in class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
getCounter(String, String) - Method in class com.splout.db.hadoop.CounterInterface
 
getCreateIndexes(TableSpec...) - Static method in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
 
getCreateTables(TableSpec...) - Static method in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
 
getEscapeChar() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
getFiles() - Method in class com.splout.db.hadoop.Table
 
getFileSchema() - Method in class com.splout.db.hadoop.TableInput
 
getFinalSQL() - Method in class com.splout.db.hadoop.TableSpec
 
getFinalStatements() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getFixedWidthFields() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
getFormat() - Method in class com.splout.db.hadoop.TableInput
 
getGt10() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 10 milliseconds
getGt100() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 100 milliseconds
getGt1000() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 1000 milliseconds
getGt250() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 250 milliseconds
getGt2500() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 2500 milliseconds
getGt50() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 50 milliseconds
getGt500() - Method in class com.splout.db.benchmark.SploutBenchmark
The frequency of queries above 500 milliseconds
getHiveDbName() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getHiveTableName() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getIndexes() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getIndexes() - Method in class com.splout.db.hadoop.TableSpec
 
getIndexFields() - Method in class com.splout.db.hadoop.TableSpec.FieldIndex
 
getInitialSQL() - Method in class com.splout.db.hadoop.TableSpec
 
getInitialStatements() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getInitStatements() - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
getInitStatements() - Method in class com.splout.db.hadoop.TablespaceSpec
 
getInputSpecs() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getInputType() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getInsertionOrderBy() - Method in class com.splout.db.hadoop.TableSpec
 
getMax() - Method in class com.splout.db.benchmark.SploutBenchmark
The maximum query response time
getMaxInputSplitSize() - Method in class com.splout.db.hadoop.TupleSampler.SamplingOptions
 
getMaxSplitsToVisit() - Method in class com.splout.db.hadoop.TupleSampler.DefaultSamplingOptions
 
getMedian() - Method in class com.splout.db.benchmark.SploutBenchmark
The median query response time
getMin() - Method in class com.splout.db.benchmark.SploutBenchmark
The minimum query response time
getName() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
getName() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getnPartitions() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
getnPartitions() - Method in class com.splout.db.hadoop.TablespaceSpec
 
getNullString() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
getPartitionByJavaScript() - Method in class com.splout.db.hadoop.TableSpec
 
getPartitionByKey(ITuple, TableSpec, JavascriptEngine) - Static method in class com.splout.db.hadoop.TablespaceGenerator
Returns the partition key either by using partition-by-fields or partition-by-javascript as configured in the Table Spec.
getPartitionedTables() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
getPartitionedTables() - Method in class com.splout.db.hadoop.TablespaceSpec
 
getPartitionFields() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getPartitionFields() - Method in class com.splout.db.hadoop.TableSpec
 
getPartitionMap() - Method in class com.splout.db.hadoop.TablespaceGenerator
Returns the generated PartitionMap.
getPaths() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
getPaths() - Method in class com.splout.db.hadoop.TableInput
 
getPercen90() - Method in class com.splout.db.benchmark.SploutBenchmark
The 90 percentil query response time
getPostInsertsSQL() - Method in class com.splout.db.hadoop.TableSpec
 
getPostInsertStatements() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getPreInsertsSQL() - Method in class com.splout.db.hadoop.TableSpec
 
getPreInsertStatements() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getProgress() - Method in class com.splout.db.common.HeartBeater
 
getQuotesChar() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
getRecordProcessor() - Method in class com.splout.db.hadoop.TableInput
 
getRecordsToSample() - Method in class com.splout.db.hadoop.TablespaceGenerator
 
getRecordWriter(TaskAttemptContext) - Method in class com.splout.db.hadoop.SQLiteOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
 
getReplicateAllTables() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
getReplicateAllTables() - Method in class com.splout.db.hadoop.TablespaceSpec
 
getReplication() - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
getSchema() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getSchema() - Method in class com.splout.db.hadoop.TableSpec
 
getSeparatorChar() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
getSourcePath() - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
getSpecificHadoopInputFormatContext() - Method in class com.splout.db.hadoop.TableInput
 
getStatementPool() - Method in class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
getStdev() - Method in class com.splout.db.benchmark.SploutBenchmark
The standard deviation of the response time
getTableInputs() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
getTablespace() - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
getTableSpec() - Method in class com.splout.db.hadoop.Table
 
getTotalRows() - Method in class com.splout.db.benchmark.SploutBenchmark
After performing the benchmark, the total number of rows hit
getTuple(String, int) - Static method in class com.splout.db.common.SploutHadoopTestUtils
Returns a Tuple conforming to a simple schema: SCHEMA.

H

HadoopIntegrationTest - Class in com.splout.db.integration
This program runs an integration test to assert that different versions of Hadoop work well with Splout.
HadoopIntegrationTest() - Constructor for class com.splout.db.integration.HadoopIntegrationTest
 
HeartBeater - Class in com.splout.db.common
A Heart Beater mostly inspired by the one in SolrOutputFormat PATCH
HeartBeater(Progressable, long) - Constructor for class com.splout.db.common.HeartBeater
Create the heart beat object thread set it to daemon priority and start the thread.

I

IdentityJob - Class in com.splout.db.benchmark
This Job implements a identity Map/Reduce in two ways: one using the plain Hadoop API and the other one using the Pangool API for parsing CSV files.
IdentityJob() - Constructor for class com.splout.db.benchmark.IdentityJob
 
IdentityRecordProcessor - Class in com.splout.db.hadoop
This is the default RecordProcessor that just bypasses the Tuples comming in from the input files.
IdentityRecordProcessor() - Constructor for class com.splout.db.hadoop.IdentityRecordProcessor
 
init(Map<String, Object>) - Method in class com.splout.db.benchmark.BenchmarkTool.BenchmarkToolStressThreadImpl
 
init(Map<String, Object>) - Method in class com.splout.db.benchmark.SploutBenchmark.StressThreadImpl
 
init(Map<String, Object>) - Method in class com.splout.db.examples.MeteoBenchmark.MeteoStressThreadImpl
 
init(Map<String, Object>) - Method in class com.splout.db.examples.PageCountsBenchmark.PageCountsStressThreadImpl
 
initialSQL(String...) - Method in class com.splout.db.hadoop.TableBuilder
 
initSql(int) - Method in class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
initStatements(String...) - Method in class com.splout.db.hadoop.TablespaceBuilder
 
InputType - Enum in com.splout.db.hadoop
 
insertionSortOrder(OrderBy) - Method in class com.splout.db.hadoop.TableBuilder
 
isSkipHeader() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
isStrictQuotes() - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 

J

JavascriptEngine - Class in com.splout.db.hadoop
An engine for embedding JavaScript into Java using Rhino, etc.
JavascriptEngine(String) - Constructor for class com.splout.db.hadoop.JavascriptEngine
 
JSONTablespaceDefinition - Class in com.splout.db.hadoop
A JSON-friendly bean that can map to a TablespaceSpec easily.
JSONTablespaceDefinition() - Constructor for class com.splout.db.hadoop.JSONTablespaceDefinition
 
JSONTablespaceDefinition.JSONTableDefinition - Class in com.splout.db.hadoop
 
JSONTablespaceDefinition.JSONTableDefinition() - Constructor for class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
JSONTablespaceDefinition.JSONTableInputDefinition - Class in com.splout.db.hadoop
 
JSONTablespaceDefinition.JSONTableInputDefinition() - Constructor for class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
JSONTablespaceDefinition.TextInputSpecs - Class in com.splout.db.hadoop
 
JSONTablespaceDefinition.TextInputSpecs() - Constructor for class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 

K

KEY_SELECTION_RANDOM - Static variable in class com.splout.db.benchmark.BenchmarkTool
 
KEY_SELECTION_ZIPFIAN - Static variable in class com.splout.db.benchmark.BenchmarkTool
 

L

LOG - Static variable in class com.splout.db.common.HeartBeater
 
LOG - Static variable in class com.splout.db.hadoop.SQLiteOutputFormat
 
LOG - Static variable in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
 

M

main(String[]) - Static method in class com.splout.db.benchmark.BenchmarkStoreTool
 
main(String[]) - Static method in class com.splout.db.benchmark.BenchmarkTool
 
main(String[]) - Static method in class com.splout.db.benchmark.IdentityJob
 
main(String[]) - Static method in class com.splout.db.examples.MeteoBenchmark
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsBenchmark
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsDataGenerator
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsExample
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsNameGenerator
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsUrlGenerator
 
main(String[]) - Static method in class com.splout.db.examples.PageCountsWebapp
 
main(String[]) - Static method in class com.splout.db.hadoop.DeployerCMD
 
main(String[]) - Static method in class com.splout.db.hadoop.Driver
 
main(String[]) - Static method in class com.splout.db.hadoop.GeneratorCMD
 
main(String[]) - Static method in class com.splout.db.hadoop.SimpleGeneratorCMD
 
main(String[]) - Static method in class com.splout.db.integration.HadoopIntegrationTest
 
main(String[]) - Static method in class com.splout.db.ToolsDriver
 
MeteoBenchmark - Class in com.splout.db.examples
A benchmark designed ot stress-test Splout with the meteorogical dataset you can find on examples/meteo.
MeteoBenchmark() - Constructor for class com.splout.db.examples.MeteoBenchmark
 
MeteoBenchmark.MeteoStressThreadImpl - Class in com.splout.db.examples
Stress thread implementation following convention from SploutBenchmark.
MeteoBenchmark.MeteoStressThreadImpl() - Constructor for class com.splout.db.examples.MeteoBenchmark.MeteoStressThreadImpl
 

N

needHeartBeat() - Method in class com.splout.db.common.HeartBeater
inform the background thread that heartbeats are to be issued.
nextQuery() - Method in class com.splout.db.benchmark.BenchmarkTool.BenchmarkToolStressThreadImpl
 
nextQuery() - Method in class com.splout.db.benchmark.SploutBenchmark.StressThreadImpl
 
nextQuery() - Method in class com.splout.db.examples.MeteoBenchmark.MeteoStressThreadImpl
 
nextQuery() - Method in class com.splout.db.examples.PageCountsBenchmark.PageCountsStressThreadImpl
 
NullableSchema - Class in com.splout.db.hadoop
 
NullableSchema() - Constructor for class com.splout.db.hadoop.NullableSchema
 
nullableSchema(Schema) - Static method in class com.splout.db.hadoop.NullableSchema
Returns a copy of the given schema, but with all fields configured as nullable.

O

of(Schema, String, Path, InputFormat<ITuple, NullWritable>, int) - Static method in class com.splout.db.hadoop.TablespaceSpec
(Common case that can be built without using the builder)
of(Configuration, String[], Path, InputFormat<ITuple, NullWritable>, int) - Static method in class com.splout.db.hadoop.TablespaceSpec
Schema-less quick tablespace builder that samples the first record of the first InputSplit in order to obtain the Table Schema.
of(Schema, String[], Path, InputFormat<ITuple, NullWritable>, int) - Static method in class com.splout.db.hadoop.TablespaceSpec
 
OUT_INIT_STATEMENTS - Static variable in class com.splout.db.hadoop.TablespaceGenerator
 
OUT_PARTITION_MAP - Static variable in class com.splout.db.hadoop.TablespaceGenerator
 
OUT_SAMPLED_INPUT - Static variable in class com.splout.db.hadoop.TablespaceGenerator
 
OUT_STORE - Static variable in class com.splout.db.hadoop.TablespaceGenerator
 

P

PageCountsBenchmark - Class in com.splout.db.examples
A benchmark designed ot stress-test Splout with the Wikipedia Page Counts dataset.
PageCountsBenchmark() - Constructor for class com.splout.db.examples.PageCountsBenchmark
 
PageCountsBenchmark.PageCountsStressThreadImpl - Class in com.splout.db.examples
Stress thread implementation following convention from SploutBenchmark.
PageCountsBenchmark.PageCountsStressThreadImpl() - Constructor for class com.splout.db.examples.PageCountsBenchmark.PageCountsStressThreadImpl
 
PageCountsDataGenerator - Class in com.splout.db.examples
A synthetic data generator for the Page Counts Example.
PageCountsDataGenerator() - Constructor for class com.splout.db.examples.PageCountsDataGenerator
 
PageCountsExample - Class in com.splout.db.examples
An advanced Splout example with the Wikipedia pagecounts dataset: http://dom.as/2007/12/10/wikipedia-page-counters/
PageCountsExample() - Constructor for class com.splout.db.examples.PageCountsExample
 
PageCountsNameGenerator - Class in com.splout.db.examples
 
PageCountsNameGenerator() - Constructor for class com.splout.db.examples.PageCountsNameGenerator
 
PageCountsRecordProcessor - Class in com.splout.db.examples
Custom record processor that filters out some records and URL-Decodes a field.
PageCountsRecordProcessor(Schema, String, String) - Constructor for class com.splout.db.examples.PageCountsRecordProcessor
 
PageCountsServlet - Class in com.splout.db.examples
Servlet that proxies AJAX request to an arbitrary QNode for implementing the frontend of the Wikipedia pagecounts example.
PageCountsServlet(SploutClient) - Constructor for class com.splout.db.examples.PageCountsServlet
 
PageCountsTrendingServlet - Class in com.splout.db.examples
Servlet that caches and returns the trending wikipedia articles from: http://www.trendingtopics.org/pages.xml?page=1
PageCountsTrendingServlet() - Constructor for class com.splout.db.examples.PageCountsTrendingServlet
 
PageCountsUrlGenerator - Class in com.splout.db.examples
 
PageCountsUrlGenerator() - Constructor for class com.splout.db.examples.PageCountsUrlGenerator
 
PageCountsWebapp - Class in com.splout.db.examples
Front-end for the Wikipedia pagecounts example.
PageCountsWebapp() - Constructor for class com.splout.db.examples.PageCountsWebapp
 
PARTITION_TUPLE_FIELD - Static variable in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
 
partitionBy(String...) - Method in class com.splout.db.hadoop.TableBuilder
 
partitionByJavaScript(String) - Method in class com.splout.db.hadoop.TableBuilder
 
partitionMap - Variable in class com.splout.db.hadoop.TablespaceGenerator
 
postInsertsSQL(String...) - Method in class com.splout.db.hadoop.TableBuilder
 
preInsertsSQL(String...) - Method in class com.splout.db.hadoop.TableBuilder
 
prepareOutput(Configuration) - Method in class com.splout.db.hadoop.TablespaceGenerator
 
printStats(PrintStream) - Method in class com.splout.db.benchmark.SploutBenchmark
 
process(ITuple, CounterInterface) - Method in class com.splout.db.examples.PageCountsRecordProcessor
 
process(ITuple, CounterInterface) - Method in class com.splout.db.hadoop.IdentityRecordProcessor
 
process(ITuple, CounterInterface) - Method in interface com.splout.db.hadoop.RecordProcessor
Custom Java business logic can be implemented here.

R

RecordProcessor - Interface in com.splout.db.hadoop
A custom Java business logic piece that can be implemented by the user and passed to a TableInput.
reduce(ITuple, Iterable<ITuple>, TupleReducer.TupleMRContext, TupleReducer<ITuple, NullWritable>.Collector) - Method in class com.splout.db.hadoop.SumReducer
 
replicateToAll() - Method in class com.splout.db.hadoop.TableBuilder
 
run(String[]) - Method in class com.splout.db.benchmark.BenchmarkStoreTool
 
run(String[]) - Method in class com.splout.db.benchmark.IdentityJob
 
run() - Method in class com.splout.db.common.HeartBeater
 
run(String[]) - Method in class com.splout.db.examples.PageCountsExample
 
run() - Method in class com.splout.db.examples.PageCountsWebapp
 
run(String[]) - Method in class com.splout.db.hadoop.DeployerCMD
 
run(String[]) - Method in class com.splout.db.hadoop.GeneratorCMD
 
run(String[]) - Method in class com.splout.db.hadoop.SimpleGeneratorCMD
 
run(String[]) - Method in class com.splout.db.integration.HadoopIntegrationTest
 

S

sample(Configuration, Path, InputFormat<ITuple, NullWritable>) - Static method in class com.splout.db.hadoop.SchemaSampler
 
sample(int, Configuration, TupleSampler.SamplingType, TupleSampler.SamplingOptions) - Method in class com.splout.db.hadoop.TablespaceGenerator
Samples the input, if needed.
sample(List<TableInput>, Schema, Configuration, long, Path) - Method in class com.splout.db.hadoop.TupleSampler
 
SCHEMA - Static variable in class com.splout.db.common.SploutHadoopTestUtils
A simple Pangool Schema called "tablespace1" made up by a string and an integer
SCHEMA - Static variable in class com.splout.db.hadoop.SQLiteOutputFormat
 
SchemaSampler - Class in com.splout.db.hadoop
Small piece of code that can sample a Pangool Schema from an arbitrary InputFormat.
SchemaSampler() - Constructor for class com.splout.db.hadoop.SchemaSampler
 
setBatchSize(int) - Method in class com.splout.db.hadoop.TablespaceGenerator
 
setCascadingColumns(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setConf(Configuration) - Method in class com.splout.db.benchmark.BenchmarkStoreTool
 
setConf(Configuration) - Method in class com.splout.db.benchmark.IdentityJob
 
setConf(Configuration) - Method in class com.splout.db.examples.PageCountsExample
 
setConf(Configuration) - Method in class com.splout.db.hadoop.DeployerCMD
 
setConf(Configuration) - Method in class com.splout.db.hadoop.GeneratorCMD
 
setConf(Configuration) - Method in class com.splout.db.hadoop.SimpleGeneratorCMD
 
setConf(Configuration) - Method in class com.splout.db.integration.HadoopIntegrationTest
 
setEscapeChar(char) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setFinalStatements(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setFixedWidthFields(ArrayList<Integer>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setHiveDbName(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setHiveTableName(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setIndexes(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setInitialStatements(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setInitStatements(List<String>) - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
setInputSpecs(JSONTablespaceDefinition.TextInputSpecs) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setInputType(InputType) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setMaxInputSplitSize(Long) - Method in class com.splout.db.hadoop.TupleSampler.SamplingOptions
 
setMaxSplitsToVisit(int) - Method in class com.splout.db.hadoop.TupleSampler.DefaultSamplingOptions
 
setName(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setName(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
setnPartitions(int) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
setNPartitions(int) - Method in class com.splout.db.hadoop.TablespaceBuilder
 
setNullString(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setPartitionedTables(List<JSONTablespaceDefinition.JSONTableDefinition>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
setPartitionFields(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setPaths(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableInputDefinition
 
setPostInsertStatements(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setPreInsertStatements(List<String>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setProgress(Progressable) - Method in class com.splout.db.common.HeartBeater
 
setQuotesChar(char) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setRecordsToSample(int) - Method in class com.splout.db.hadoop.TablespaceGenerator
 
setReplicateAllTables(List<JSONTablespaceDefinition.JSONTableDefinition>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition
 
setReplication(int) - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
setSchema(String) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setSeparatorChar(char) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setSkipHeader(boolean) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setSourcePath(String) - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
setStatus(String) - Method in class com.splout.db.common.HeartBeater
 
setStrictQuotes(boolean) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.TextInputSpecs
 
setTableInputs(List<JSONTablespaceDefinition.JSONTableInputDefinition>) - Method in class com.splout.db.hadoop.JSONTablespaceDefinition.JSONTableDefinition
 
setTablespace(String) - Method in class com.splout.db.hadoop.TablespaceDepSpec
 
SimpleGeneratorCMD - Class in com.splout.db.hadoop
This tool can be used for creating and deploying a single-table tablespace from text files.
SimpleGeneratorCMD() - Constructor for class com.splout.db.hadoop.SimpleGeneratorCMD
 
SimpleGeneratorCMD.CharConverter - Class in com.splout.db.hadoop
 
SimpleGeneratorCMD.CharConverter() - Constructor for class com.splout.db.hadoop.SimpleGeneratorCMD.CharConverter
 
SploutBenchmark - Class in com.splout.db.benchmark
Generic benchmark implementation for Splout.
SploutBenchmark() - Constructor for class com.splout.db.benchmark.SploutBenchmark
 
SploutBenchmark.StressThreadImpl - Class in com.splout.db.benchmark
Subclasses of this class can be used for performing arbitrary benchmarks.
SploutBenchmark.StressThreadImpl() - Constructor for class com.splout.db.benchmark.SploutBenchmark.StressThreadImpl
 
SploutHadoopConfiguration - Class in com.splout.db.common
Configuratio helper class.
SploutHadoopConfiguration() - Constructor for class com.splout.db.common.SploutHadoopConfiguration
 
SploutHadoopTestUtils - Class in com.splout.db.common
Testing helper class.
SploutHadoopTestUtils() - Constructor for class com.splout.db.common.SploutHadoopTestUtils
 
SQLiteOutputFormat - Class in com.splout.db.hadoop
Low-level Pangool OutputFormat that can be used to generate partitioned SQL views in Hadoop.
SQLiteOutputFormat(String[], String[], int) - Constructor for class com.splout.db.hadoop.SQLiteOutputFormat
 
SQLiteOutputFormat.SQLRecordWriter - Class in com.splout.db.hadoop
 
SQLiteOutputFormat.SQLRecordWriter(TaskAttemptContext) - Constructor for class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
start() - Method in class com.splout.db.benchmark.BenchmarkTool
 
start() - Method in class com.splout.db.examples.MeteoBenchmark
 
start() - Method in class com.splout.db.examples.PageCountsBenchmark
 
StoreDeployerTool - Class in com.splout.db.hadoop
A generic class for deploying an already generated store by TablespaceGenerator.
StoreDeployerTool(String, Configuration) - Constructor for class com.splout.db.hadoop.StoreDeployerTool
 
stressTest(int, int, Class<? extends SploutBenchmark.StressThreadImpl>, Map<String, Object>) - Method in class com.splout.db.benchmark.SploutBenchmark
 
SumReducer - Class in com.splout.db.hadoop
Reusable TupleReducer that aggregates the counts of a certain field in the Tuple.
SumReducer(String) - Constructor for class com.splout.db.hadoop.SumReducer
Will (int) sum the field "field"

T

Table - Class in com.splout.db.hadoop
Immutable definition of a Splout Table whose view has to be generated.
TableBuilder - Class in com.splout.db.hadoop
This builder can be used to obtain Table beans.
TableBuilder(Schema) - Constructor for class com.splout.db.hadoop.TableBuilder
Fixed schema constructor: for example, if we use textual files.
TableBuilder(String, Schema) - Constructor for class com.splout.db.hadoop.TableBuilder
Fixed schema + explicit table name.
TableBuilder(Configuration) - Constructor for class com.splout.db.hadoop.TableBuilder
Hadoop configuration, no schema: The input files will contain the Schema (e.g.
TableBuilder(String, Configuration) - Constructor for class com.splout.db.hadoop.TableBuilder
Schema-less constructor with explicit table name.
TableBuilder.TableBuilderException - Exception in com.splout.db.hadoop
Exception that is thrown if a Table cannot be built because there is missing data or inconsistent data has been specified.
TableBuilder.TableBuilderException(String) - Constructor for exception com.splout.db.hadoop.TableBuilder.TableBuilderException
 
TableInput - Class in com.splout.db.hadoop
A file (represented by a Hadoop Path) associated with an Pangool's InputFormat.
TABLESPACE - Static variable in class com.splout.db.examples.PageCountsBenchmark
 
tablespace - Variable in class com.splout.db.hadoop.TablespaceGenerator
 
TablespaceBuilder - Class in com.splout.db.hadoop
This class is the main entry point for generating Splout views.
TablespaceBuilder() - Constructor for class com.splout.db.hadoop.TablespaceBuilder
 
TablespaceBuilder.TablespaceBuilderException - Exception in com.splout.db.hadoop
Exception that is thrown if a Tablespace cannot be built because there is missing data or inconsistent data has been specified.
TablespaceBuilder.TablespaceBuilderException(String) - Constructor for exception com.splout.db.hadoop.TablespaceBuilder.TablespaceBuilderException
 
TablespaceDepSpec - Class in com.splout.db.hadoop
Convenience bean used in tools such as DeployerCMD
TablespaceDepSpec() - Constructor for class com.splout.db.hadoop.TablespaceDepSpec
 
TablespaceDepSpec(String, String, int, List<String>) - Constructor for class com.splout.db.hadoop.TablespaceDepSpec
 
TablespaceGenerator - Class in com.splout.db.hadoop
A process that generates the SQL data stores needed for deploying a tablespace in Splout, giving a file set table specification as input.
TablespaceGenerator(TablespaceSpec, Path, Class) - Constructor for class com.splout.db.hadoop.TablespaceGenerator
 
TablespaceGenerator.TablespaceGeneratorException - Exception in com.splout.db.hadoop
 
TablespaceGenerator.TablespaceGeneratorException() - Constructor for exception com.splout.db.hadoop.TablespaceGenerator.TablespaceGeneratorException
 
TablespaceGenerator.TablespaceGeneratorException(String, Throwable) - Constructor for exception com.splout.db.hadoop.TablespaceGenerator.TablespaceGeneratorException
 
TablespaceGenerator.TablespaceGeneratorException(String) - Constructor for exception com.splout.db.hadoop.TablespaceGenerator.TablespaceGeneratorException
 
TablespaceGenerator.TablespaceGeneratorException(Throwable) - Constructor for exception com.splout.db.hadoop.TablespaceGenerator.TablespaceGeneratorException
 
TablespaceSpec - Class in com.splout.db.hadoop
Immutable bean that defines a Tablespace whose view has to be generated.
TableSpec - Class in com.splout.db.hadoop
Simple immutable bean that specifies the Pangool Schema of a Splout Table and the Fields that need to be indexed and how it is partitioned.
TableSpec(Schema, Schema.Field) - Constructor for class com.splout.db.hadoop.TableSpec
Simple TableSpec constructor that creates one TableSpec for a schema with a single partition field that is also indexed.
TableSpec(Schema, Schema.Field[], TableSpec.FieldIndex[], String[], String[], String[], String[], OrderBy) - Constructor for class com.splout.db.hadoop.TableSpec
Creates a Table specification.
TableSpec(Schema, String, TableSpec.FieldIndex[], String[], String[], String[], String[], OrderBy) - Constructor for class com.splout.db.hadoop.TableSpec
Creates a Table specification.
TableSpec.FieldIndex - Class in com.splout.db.hadoop
A database index made up by one or more Pangool Fields.
TableSpec.FieldIndex(Schema.Field) - Constructor for class com.splout.db.hadoop.TableSpec.FieldIndex
 
TableSpec.FieldIndex(Schema.Field...) - Constructor for class com.splout.db.hadoop.TableSpec.FieldIndex
 
ToolsDriver - Class in com.splout.db
Driver to run different Splout tools TODO Merge with the other Driver?
ToolsDriver() - Constructor for class com.splout.db.ToolsDriver
 
toString() - Method in class com.splout.db.hadoop.TableSpec.FieldIndex
 
TupleSampler - Class in com.splout.db.hadoop
This class samples a list of TableInput files that produce a certain Table Schema.
TupleSampler(TupleSampler.SamplingType, TupleSampler.SamplingOptions) - Constructor for class com.splout.db.hadoop.TupleSampler
 
TupleSampler.DefaultSamplingOptions - Class in com.splout.db.hadoop
 
TupleSampler.DefaultSamplingOptions() - Constructor for class com.splout.db.hadoop.TupleSampler.DefaultSamplingOptions
 
TupleSampler.SamplingOptions - Class in com.splout.db.hadoop
 
TupleSampler.SamplingOptions() - Constructor for class com.splout.db.hadoop.TupleSampler.SamplingOptions
 
TupleSampler.SamplingType - Enum in com.splout.db.hadoop
 
TupleSampler.TupleSamplerException - Exception in com.splout.db.hadoop
 
TupleSampler.TupleSamplerException(String) - Constructor for exception com.splout.db.hadoop.TupleSampler.TupleSamplerException
 
TupleSampler.TupleSamplerException(Exception) - Constructor for exception com.splout.db.hadoop.TupleSampler.TupleSamplerException
 
TupleSQLite4JavaOutputFormat - Class in com.splout.db.hadoop
An OutputFormat that accepts Pangool's Tuples and writes to a sqlite4Java SQLite file.
TupleSQLite4JavaOutputFormat(int, TableSpec...) - Constructor for class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat
This OutputFormat receives a list of TableSpec.
TupleSQLite4JavaOutputFormat.TupleSQLiteOutputFormatException - Exception in com.splout.db.hadoop
Exception that is thrown if the Output Format cannot be instantiated because the specified parameters are inconsistent or invalid.
TupleSQLite4JavaOutputFormat.TupleSQLiteOutputFormatException(String) - Constructor for exception com.splout.db.hadoop.TupleSQLite4JavaOutputFormat.TupleSQLiteOutputFormatException
 
TupleSQLite4JavaOutputFormat.TupleSQLiteOutputFormatException(String, Exception) - Constructor for exception com.splout.db.hadoop.TupleSQLite4JavaOutputFormat.TupleSQLiteOutputFormatException
 
TupleSQLite4JavaOutputFormat.TupleSQLRecordWriter - Class in com.splout.db.hadoop
A RecordWriter that accepts an Int(Partition), a Tuple and delegates to a SQLiteOutputFormat.SQLRecordWriter converting the Tuple into SQL and assigning the partition that comes in the Key.
TupleSQLite4JavaOutputFormat.TupleSQLRecordWriter(TaskAttemptContext) - Constructor for class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat.TupleSQLRecordWriter
 

V

valueOf(String) - Static method in enum com.splout.db.hadoop.InputType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.splout.db.hadoop.TupleSampler.SamplingType
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.splout.db.hadoop.InputType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.splout.db.hadoop.TupleSampler.SamplingType
Returns an array containing the constants of this enum type, in the order they are declared.

W

WAIT_TIME_CONF - Static variable in class com.splout.db.common.HeartBeater
 
write(ITuple, NullWritable) - Method in class com.splout.db.hadoop.SQLiteOutputFormat.SQLRecordWriter
 
write(ITuple, NullWritable) - Method in class com.splout.db.hadoop.TupleSQLite4JavaOutputFormat.TupleSQLRecordWriter
 
writeOutputMetadata(Configuration) - Method in class com.splout.db.hadoop.TablespaceGenerator
Write the partition map and other metadata to the output folder.

A B C D E F G H I J K L M N O P R S T V W

Copyright © 2012-2013 Datasalt Systems S.L.. All Rights Reserved.