Package | Description |
---|---|
org.apache.flink.runtime.accumulators | |
org.apache.flink.runtime.io.network.api.reader | |
org.apache.flink.runtime.io.network.api.serialization | |
org.apache.flink.runtime.io.network.api.writer | |
org.apache.flink.runtime.operators | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
AccumulatorRegistry.Reporter |
AccumulatorRegistry.getReadWriteReporter()
Gets the reporter for flink internal metrics.
|
Modifier and Type | Method and Description |
---|---|
void |
ReaderBase.setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
Modifier and Type | Method and Description |
---|---|
void |
SpillingAdaptiveSpanningRecordDeserializer.setReporter(AccumulatorRegistry.Reporter reporter) |
void |
SpanningRecordSerializer.setReporter(AccumulatorRegistry.Reporter reporter) |
void |
RecordSerializer.setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
void |
RecordDeserializer.setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
void |
AdaptiveSpanningRecordDeserializer.setReporter(AccumulatorRegistry.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriter.setReporter(AccumulatorRegistry.Reporter reporter)
Counter for the number of records emitted and the records processed.
|
Modifier and Type | Method and Description |
---|---|
static <T> Collector<T> |
BatchTask.getOutputCollector(AbstractInvokable task,
TaskConfig config,
ClassLoader cl,
List<RecordWriter<?>> eventualOutputs,
int outputOffset,
int numOutputs,
AccumulatorRegistry.Reporter reporter)
Creates the
Collector for the given task, as described by the given configuration. |
static <T> Collector<T> |
BatchTask.initOutputs(AbstractInvokable containingTask,
ClassLoader cl,
TaskConfig config,
List<ChainedDriver<?,?>> chainedTasksTarget,
List<RecordWriter<?>> eventualOutputs,
ExecutionConfig executionConfig,
AccumulatorRegistry.Reporter reporter,
Map<String,Accumulator<?,?>> accumulatorMap)
Creates a writer for each output.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamTwoInputProcessor.setReporter(AccumulatorRegistry.Reporter reporter) |
void |
StreamInputProcessor.setReporter(AccumulatorRegistry.Reporter reporter) |
Constructor and Description |
---|
OperatorChain(StreamTask<OUT,?> containingTask,
StreamOperator<OUT> headOperator,
AccumulatorRegistry.Reporter reporter) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.