Modifier and Type | Class and Description |
---|---|
protected class |
SysomosHeartbeatStream.QueryResult |
Constructor and Description |
---|
SysomosHeartbeatStream(SysomosProvider provider,
String heartbeatId) |
SysomosHeartbeatStream(SysomosProvider provider,
String heartbeatId,
org.joda.time.DateTime beforeTime,
org.joda.time.DateTime afterTime) |
SysomosHeartbeatStream(SysomosProvider provider,
String heartbeatId,
String documentId) |
SysomosHeartbeatStream(SysomosProvider provider,
String heartbeatId,
org.apache.streams.sysomos.provider.SysomosHeartbeatStream.OperatingMode mode) |
Modifier and Type | Method and Description |
---|---|
protected BeatApi.BeatResponse |
executeAPIRequest() |
protected void |
executeRun() |
protected SysomosHeartbeatStream.QueryResult |
queryAPI() |
void |
run() |
protected void |
shutdown() |
protected void |
sleep() |
protected void |
updateOffset(SysomosHeartbeatStream.QueryResult result) |
protected void |
updateState(SysomosHeartbeatStream.QueryResult result,
String mostCurrentId,
int totalDocCount) |
public SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId)
public SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, org.joda.time.DateTime beforeTime, org.joda.time.DateTime afterTime)
public SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, String documentId)
public SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, org.apache.streams.sysomos.provider.SysomosHeartbeatStream.OperatingMode mode)
protected void executeRun()
protected void updateState(SysomosHeartbeatStream.QueryResult result, String mostCurrentId, int totalDocCount)
protected void updateOffset(SysomosHeartbeatStream.QueryResult result)
protected void sleep()
protected SysomosHeartbeatStream.QueryResult queryAPI()
protected BeatApi.BeatResponse executeAPIRequest()
protected void shutdown()
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.