@Internal public class StreamProject<IN,OUT extends Tuple> extends AbstractStreamOperator<OUT> implements OneInputStreamOperator<IN,OUT>
AbstractStreamOperator.CountingOutput
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
StreamProject(int[] fields,
TypeSerializer<OUT> outSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
open()
This method is called immediately before any elements are processed, it should contain the
operator's initialization logic.
|
void |
processElement(StreamRecord<IN> element)
Processes one element that arrived at this operator.
|
void |
processWatermark(Watermark mark)
Processes a
Watermark . |
close, dispose, getChainingStrategy, getContainingTask, getCurrentProcessingTime, getExecutionConfig, getMetricGroup, getOperatorConfig, getOperatorName, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, notifyOfCompletedCheckpoint, registerTimer, restoreState, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, dispose, getChainingStrategy, getMetricGroup, notifyOfCompletedCheckpoint, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
public StreamProject(int[] fields, TypeSerializer<OUT> outSerializer)
public void processElement(StreamRecord<IN> element) throws Exception
OneInputStreamOperator
processElement
in interface OneInputStreamOperator<IN,OUT extends Tuple>
Exception
public void open() throws Exception
AbstractStreamOperator
The default implementation does nothing.
open
in interface StreamOperator<OUT extends Tuple>
open
in class AbstractStreamOperator<OUT extends Tuple>
Exception
- An exception in this method causes the operator to fail.public void processWatermark(Watermark mark) throws Exception
OneInputStreamOperator
Watermark
.
This method is guaranteed to not be called concurrently with other methods of the operator.processWatermark
in interface OneInputStreamOperator<IN,OUT extends Tuple>
Exception
Watermark
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.