public abstract class OutputAdapter extends Operator implements IOutputAdapter
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.ArtifactProperties, 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, getArtifactManager, getAsyncInputPorts, getCaptureStrategy, getContainerName, getDataDirectory, getDisplayDescription, getDisplayName, getDynamicVariables, getDynamicVariablesSchema, getFullyQualifiedName, getIconResource, getInputPortCount, getInputSchema, getLocation, getLocation, getLock, getLogger, getManagedState, getName, getNamedSchema, getOperatorConfigurationAccessor, getOutputPortCount, getOutputSchema, getParameters, getPortCounts, getProposedInputSchemas, getProposedOutputSchemas, getResourceContents, getResourceFile, getReuseTuple, getRuntimeEnvironment, getRuntimeInputSchema, getRuntimeOutputSchema, getSchemaForCapture, getSearchKeywords, getShortDisplayName, getStateChangeTimeout, getStorageMethod, getTableAccessor, getTransactionIsolationLevel, getTupleCaptureTransformer, getTypecheckInputSchema, getTypecheckOutputSchema, hasNotYetStarted, init, isConcurrentByDefault, isDroppingTuples, isPassthruOperator, isProcessingTuples, isRunning, isRuntime, isShutdown, isSuspended, postShutdown, processTuple, registerRunnable, registerRunnable, registerRunnable, registerRunnable, remoteNodeActive, remoteNodeUnavailable, requireInputPortCount, resume, resumed, scheduleRunnable, sendErrorOutput, sendErrorOutput, sendErrorOutput, sendOutput, sendOutput, sendOutputAsync, sendOutputAsync, setCaptureStrategy, setDisplayDescription, setDisplayName, setDynamicVariable, setLogLevel, setLogLevel, setManagedState, setOutputSchema, setParameters, setPortHints, setReuseTuple, setShortDisplayName, setSuspendBehavior, shouldRun, shutdown, size, supportsArtifacts, supportsTransactionalMemory, suspend, suspended, typecheckCopyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.