public abstract class OutputAdapter extends Operator
Output adapters should override Operator.processTuple(int, Tuple)
to receive tuples from the application.
For in-depth information on implementing a custom adapter, please see "Using the Embedded Adapter API" in the StreamBase documentation.
Operator.ConfigurationAccessor, Operator.IconKind, Operator.LogLevel, Operator.OperatorStates, Operator.OperatorThread, Operator.PropertyTypecheckException, Operator.RuntimeEnvironment, Operator.SharedObject, Operator.SharedObjectManager, Operator.SuspendBehaviorStatesDEFAULT_STATE_CHANGE_TIMEOUT, OP_CONFIG_MGR_NO_CONF| Constructor and Description |
|---|
OutputAdapter() |
allowsConcurrency, evaluate, getCaptureStrategy, getContainerName, getDisplayName, getFullyQualifiedName, getIconResource, getInputPortCount, getInputSchema, getLocation, getLocation, getLogger, getName, getOperatorConfigurationAccessor, getOutputPortCount, getOutputSchema, getParameters, getPortCounts, getProposedInputSchemas, getProposedOutputSchemas, getResourceContents, getResourceFile, getReuseTuple, getRuntimeEnvironment, getRuntimeInputSchema, getRuntimeOutputSchema, getSchemaForCapture, getSearchKeywords, getShortDisplayName, getStateChangeTimeout, getTableAccessor, getTupleCaptureTransformer, getTypecheckInputSchema, getTypecheckOutputSchema, hasNotYetStarted, init, isDesignTime, isDroppingTuples, isPassthruOperator, isProcessingTuples, isRunning, isShutdown, isSuspended, postShutdown, processTuple, registerRunnable, registerRunnable, registerRunnable, registerRunnable, requireInputPortCount, resume, resumed, scheduleRunnable, sendErrorOutput, sendErrorOutput, sendErrorOutput, sendOutput, sendOutput, sendOutputAsync, sendOutputAsync, setCaptureStrategy, setDisplayName, setLogLevel, setLogLevel, setOutputSchema, setParameters, setPortHints, setReuseTuple, setShortDisplayName, setSuspendBehavior, shouldRun, shutdown, size, suspend, suspended, typecheck