public class TruncatePartitionHandler extends Object
MessageHandler.Context| Constructor and Description |
|---|
TruncatePartitionHandler() |
| Modifier and Type | Method and Description |
|---|---|
UpdatedMetaDataTracker |
getUpdatedMetadata() |
List<Task<? extends Serializable>> |
handle(MessageHandler.Context context) |
Set<ReadEntity> |
readEntities() |
Set<WriteEntity> |
writeEntities() |
public List<Task<? extends Serializable>> handle(MessageHandler.Context context) throws SemanticException
SemanticExceptionpublic Set<ReadEntity> readEntities()
readEntities in interface MessageHandlerpublic Set<WriteEntity> writeEntities()
writeEntities in interface MessageHandlerpublic UpdatedMetaDataTracker getUpdatedMetadata()
getUpdatedMetadata in interface MessageHandlerCopyright © 2019 The Apache Software Foundation. All Rights Reserved.