SPL File CrossDataCenterFailover.spl
- Example
- The following is a code block that demonstrates how to invoke the CrossDataCenterFailover composite operator within an Streams application:
Content
- Operators
Composites
composite CrossDataCenterFailover(output DataSnapshotSignal, RemoteDataCenterStatus, ProcessDataFromRemoteDC; input SerializedDataSnapshotMessage, SpecialMessage)
Parameters
- localDataCenterName
- crossDCOperationMode
- crossDCHttpPort
- remoteDataCenterApplicationMachineNames
- crossDCInitDelay
- heartbeatExchangeInterval
- consecutiveHeartbeatMissesAllowed
- dataSnapshotExchangeInterval
- dataSnapshotStorageDirectory
- dataSnapshotJdbcUrl
- dataSnapshotJdbcUser
- dataSnapshotJdbcPassword
- dataSnapshotJdbcDriverLib
- dataSnapshotJdbcClassName
- dataSnapshotTableName
- dataSnapshotPrimaryKeyColumnName
- sendToAllRemoteMachines
- alwaysLogHttpErrors
- httpConnectionTimeout
- httpReadTimeout
- numberOfHttpSenderReceiverPairs
- remoteDataCenterUrlPathForHeartbeatReceiver
- remoteDataCenterUrlPath
- retainOlderDataSnapshotsAtStartup
- sendDataSnapshotsToOriginDCAtStartup
- configFileName
- localDataCenterNameKey
- crossDCOperationModeKey
- crossDCHttpPortKey
- remoteDataCenterApplicationMachineNamesKey
- dataSnapshotStorageDirectoryKey
- dataSnapshotJdbcUrlKey
- dataSnapshotJdbcUserKey
- dataSnapshotJdbcPasswordKey
- dataSnapshotJdbcDriverLibKey
- dataSnapshotJdbcClassNameKey
- dataSnapshotTableNameKey
- dataSnapshotPrimaryKeyColumnNameKey
- crossDCInitDelayKey
- heartbeatExchangeIntervalKey
- consecutiveHeartbeatMissesAllowedKey
- dataSnapshotExchangeIntervalKey
- sendToAllRemoteMachinesKey
- alwaysLogHttpErrorsKey
- httpConnectionTimeoutKey
- httpReadTimeoutKey
- retainOlderDataSnapshotsAtStartupKey
- sendDataSnapshotsToOriginDCAtStartupKey
Input Ports
- SerializedDataSnapshotMessage
- SpecialMessage
Output Ports
- DataSnapshotSignal
- RemoteDataCenterStatus
- ProcessDataFromRemoteDC