Modifier and Type | Method and Description |
---|---|
Context |
BasicIRCStreamDataset.construct(String channel,
String sender,
String login,
String hostname,
String message) |
Constructor and Description |
---|
BasicIRCStreamDataset(BlockingDroppingQueue<Context> buffer,
String hostname,
String channel)
Construct with the given buffer, connecting to the given host and
channel.
|
Constructor and Description |
---|
ContextRoundRobinTwitterSearchAPIDataset(List<twitter4j.Query> queries,
TwitterAPIToken token,
BlockingDroppingQueue<Context> buffer) |
Modifier and Type | Method and Description |
---|---|
Context |
Context.clone() |
Context |
Context.combine(Context that,
String thisprefix,
String thatprefix)
|
Modifier and Type | Method and Description |
---|---|
Context |
Context.combine(Context that,
String thisprefix,
String thatprefix)
|
Modifier and Type | Method and Description |
---|---|
Context |
ContextListFunction.apply(Context in) |
Context |
ContextFunctionAdaptor.apply(Context in) |
Context |
ContextListFilter.apply(Context in) |
Context |
ContextGenerator.apply(T in) |
Modifier and Type | Method and Description |
---|---|
static <IN> Operation<Context> |
ContextOperationAdaptor.create(Operation<IN> operation,
String extract)
Helper to create a new
ContextOperationAdaptor . |
static <IN,OUT> Function<Context,Context> |
ContextFunctionAdaptor.create(String extract,
String insert,
Function<IN,OUT> inner)
Create a new
ContextFunctionAdaptor that reads data from a given
key, applies a function and sets the result in a different key. |
static <IN,OUT> Function<Context,Context> |
ContextFunctionAdaptor.create(String extract,
String insert,
Function<IN,OUT> inner)
Create a new
ContextFunctionAdaptor that reads data from a given
key, applies a function and sets the result in a different key. |
Modifier and Type | Method and Description |
---|---|
T |
ContextTransform.apply(Context in) |
Context |
ContextListFunction.apply(Context in) |
Context |
ContextFunctionAdaptor.apply(Context in) |
Context |
ContextListFilter.apply(Context in) |
T |
ContextExtractor.extract(Context c)
Extract the data from the context
|
T |
KeyContextExtractor.extract(Context c) |
void |
KeyContextInsertor.insert(T obj,
Context c) |
void |
ContextInsertor.insert(T obj,
Context c)
Insert the object into the context
|
void |
ContextOperationAdaptor.perform(Context object) |
boolean |
ContextPredicateAdaptor.test(Context in) |
Modifier and Type | Method and Description |
---|---|
OUT |
ContextListTransformFunction.apply(List<Context> in) |
List<T> |
ContextListTransform.apply(List<Context> in) |
Modifier and Type | Method and Description |
---|---|
Context |
ContextStreamCombiner.next() |
Modifier and Type | Method and Description |
---|---|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
Modifier and Type | Method and Description |
---|---|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
Constructor and Description |
---|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b)
Construct the combiner to consume the two given streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b)
Construct the combiner to consume the two given streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b,
String aprefix,
String bprefix)
Construct the combiner to consume the two given streams, using the given
prefixes to modify the keys from the respective streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b,
String aprefix,
String bprefix)
Construct the combiner to consume the two given streams, using the given
prefixes to modify the keys from the respective streams.
|
Modifier and Type | Method and Description |
---|---|
Stream<Context> |
ContextRealTimeWindowFunction.apply(Stream<IN> inner) |