A C E F G N O S

A

addStreamsPersistWriter(String, StreamsPersistWriter, int, String...) - Method in class org.apache.streams.pig.StreamsPigBuilder

addStreamsProcessor(String, StreamsProcessor, int, String...) - Method in class org.apache.streams.pig.StreamsPigBuilder

C

call(String) - Method in class org.apache.streams.pig.StreamsProcessDocumentExec

E

exec(Tuple) - Method in class org.apache.streams.pig.StreamsProcessDatumExec

F

finish() - Method in class org.apache.streams.pig.StreamsProcessDatumExec

finish() - Method in class org.apache.streams.pig.StreamsProcessDocumentExec

G

getConverterInstance(Class<?>) - Static method in class org.apache.streams.pig.StreamsComponentFactory

getOutputSchema(Schema) - Method in class org.apache.streams.pig.StreamsProcessDatumExec

getProcessorInstance(Class<?>) - Static method in class org.apache.streams.pig.StreamsComponentFactory

getStreamsConfiguration() - Method in class org.apache.streams.pig.StreamsPigBuilder

N

newPerpetualStream(String, StreamsProvider) - Method in class org.apache.streams.pig.StreamsPigBuilder

newReadCurrentStream(String, StreamsProvider) - Method in class org.apache.streams.pig.StreamsPigBuilder

newReadNewStream(String, StreamsProvider, BigInteger) - Method in class org.apache.streams.pig.StreamsPigBuilder

newReadRangeStream(String, StreamsProvider, DateTime, DateTime) - Method in class org.apache.streams.pig.StreamsPigBuilder

O

org.apache.streams.pig - package org.apache.streams.pig

S

setStreamsConfiguration(StreamsConfiguration) - Method in class org.apache.streams.pig.StreamsPigBuilder

start() - Method in class org.apache.streams.pig.StreamsPigBuilder

stop() - Method in class org.apache.streams.pig.StreamsPigBuilder

StreamsComponentFactory - Class in org.apache.streams.pig

Static reflection wrappers for instantiating StreamsComponents

StreamsComponentFactory() - Constructor for class org.apache.streams.pig.StreamsComponentFactory

StreamsPigBuilder - Class in org.apache.streams.pig

Goal is to be able to build a pig workflow using same syntax as other StreamsBuilders Currently implementers must write own pig scripts to use this module

StreamsPigBuilder() - Constructor for class org.apache.streams.pig.StreamsPigBuilder

StreamsProcessDatumExec - Class in org.apache.streams.pig

UDF Wrapper at the Datum / Map Input Record level

StreamsProcessDatumExec(String...) - Constructor for class org.apache.streams.pig.StreamsProcessDatumExec

StreamsProcessDocumentExec - Class in org.apache.streams.pig

UDF Wrapper at the Document level Useful when id,source,timestamp are not changing or you want to use pig to modify them (rather than doing so within the processor)

StreamsProcessDocumentExec(String...) - Constructor for class org.apache.streams.pig.StreamsProcessDocumentExec

StreamsStorage - Class in org.apache.streams.pig

It would be nice if streams persisters could be used for input / output within the pig runtime.

StreamsStorage() - Constructor for class org.apache.streams.pig.StreamsStorage

A C E F G N O S