public class CassandraCommitter extends CheckpointCommitter
jobId, LOG, operatorId, subtaskId
Constructor and Description |
---|
CassandraCommitter(ClusterBuilder builder) |
CassandraCommitter(ClusterBuilder builder,
String keySpace) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the resource/connection to it.
|
void |
commitCheckpoint(long checkpointID)
Mark the given checkpoint as completed in the resource.
|
void |
createResource()
Generates the necessary tables to store information.
|
boolean |
isCheckpointCommitted(long checkpointID)
Checked the resource whether the given checkpoint was committed completely.
|
void |
open()
Opens/connects to the resource, and possibly creates it beforehand.
|
void |
setJobId(String id)
Internally used to set the job ID after instantiation.
|
setOperatorId, setOperatorSubtaskId
public CassandraCommitter(ClusterBuilder builder)
public CassandraCommitter(ClusterBuilder builder, String keySpace)
public void setJobId(String id) throws Exception
setJobId
in class CheckpointCommitter
id
- Exception
public void createResource() throws Exception
createResource
in class CheckpointCommitter
Exception
public void open() throws Exception
CheckpointCommitter
open
in class CheckpointCommitter
Exception
public void close() throws Exception
CheckpointCommitter
close
in class CheckpointCommitter
Exception
public void commitCheckpoint(long checkpointID)
CheckpointCommitter
commitCheckpoint
in class CheckpointCommitter
public boolean isCheckpointCommitted(long checkpointID)
CheckpointCommitter
isCheckpointCommitted
in class CheckpointCommitter
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.