Add stateful support in heron api Config
diff --git a/heron/api/src/java/com/twitter/heron/api/Config.java b/heron/api/src/java/com/twitter/heron/api/Config.java
index 412c1c6..58c47db 100644
--- a/heron/api/src/java/com/twitter/heron/api/Config.java
+++ b/heron/api/src/java/com/twitter/heron/api/Config.java
@@ -147,6 +147,32 @@
*/
public static final String TOPOLOGY_COMPONENT_RAMMAP = "topology.component.rammap";
/**
+ * Is this topology stateful? The format of this flag is boolean
+ */
+ public static final String TOPOLOGY_STATEFUL = "topology.stateful";
+ /**
+ * What's the checkpoint interval for stateful topologies in seconds
+ */
+ public static final String TOPOLOGY_STATEFUL_CHECKPOINT_INTERVAL =
+ "topology.stateful.checkpoint.interval";
+ /**
+ * What's the provider for state? i.e. one where state is stored
+ */
+ public static final String TOPOLOGY_STATEFUL_PROVIDER_TYPE =
+ "topology.stateful.provider.type";
+ /**
+ * What's the config for state provider?
+ */
+ public static final String TOPOLOGY_STATEFUL_PROVIDER_CONFIG =
+ "topology.stateful.provider.config";
+
+ /**
+ * Boolean flag that says that the stateful topology should start from
+ * clean state, i.e. ignore any checkpoint state
+ */
+ public static final String TOPOLOGY_STATEFUL_START_CLEAN =
+ "topology.stateful.start.clean";
+ /**
* Name of the topology. This config is automatically set by Heron when the topology is submitted.
*/
public static final String TOPOLOGY_NAME = "topology.name";
@@ -209,6 +235,11 @@
apiVars.add(TOPOLOGY_CONTAINER_MAX_RAM_HINT);
apiVars.add(TOPOLOGY_CONTAINER_PADDING_PERCENTAGE);
apiVars.add(TOPOLOGY_COMPONENT_RAMMAP);
+ apiVars.add(TOPOLOGY_STATEFUL_START_CLEAN);
+ apiVars.add(TOPOLOGY_STATEFUL_CHECKPOINT_INTERVAL);
+ apiVars.add(TOPOLOGY_STATEFUL_PROVIDER_TYPE);
+ apiVars.add(TOPOLOGY_STATEFUL_PROVIDER_CONFIG);
+ apiVars.add(TOPOLOGY_STATEFUL);
apiVars.add(TOPOLOGY_NAME);
apiVars.add(TOPOLOGY_TEAM_NAME);
apiVars.add(TOPOLOGY_TEAM_EMAIL);
