Package org.apache.ignite.dump
Class JsonDumpConsumer
- java.lang.Object
- 
- org.apache.ignite.dump.JsonDumpConsumer
 
- 
- All Implemented Interfaces:
- DumpConsumer,- org.apache.ignite.internal.processors.cache.persistence.snapshot.dump.DumpConsumerKernalContextAware
 
 public class JsonDumpConsumer extends Object implements org.apache.ignite.internal.processors.cache.persistence.snapshot.dump.DumpConsumerKernalContextAware Dump consumer that outputs entries in json format.
- 
- 
Constructor SummaryConstructors Constructor Description JsonDumpConsumer()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonCacheConfigs(Iterator<org.apache.ignite.internal.processors.cache.StoredCacheData> caches)Handles cache configs.voidonMappings(Iterator<TypeMapping> mappings)Handles type mappings.voidonPartition(int grp, int part, Iterator<DumpEntry> data)Handles cache data.voidonTypes(Iterator<BinaryType> types)Handles binary types.voidstart()Starts the consumer.voidstart(org.apache.ignite.internal.GridKernalContext ctx)Starts the consumer with the kernal context provided.voidstop()Stops the consumer.
 
- 
- 
- 
Method Detail- 
startpublic void start(org.apache.ignite.internal.GridKernalContext ctx) Starts the consumer with the kernal context provided.- Specified by:
- startin interface- org.apache.ignite.internal.processors.cache.persistence.snapshot.dump.DumpConsumerKernalContextAware
- Parameters:
- ctx- Kernal context.
 
 - 
onMappingspublic void onMappings(Iterator<TypeMapping> mappings) Handles type mappings.- Specified by:
- onMappingsin interface- DumpConsumer
- Parameters:
- mappings- Mappings iterator.
 
 - 
onTypespublic void onTypes(Iterator<BinaryType> types) Handles binary types.- Specified by:
- onTypesin interface- DumpConsumer
- Parameters:
- types- Binary types iterator.
 
 - 
onCacheConfigspublic void onCacheConfigs(Iterator<org.apache.ignite.internal.processors.cache.StoredCacheData> caches) Handles cache configs. Note, there can be several copies of cache config in the dump. This can happen if dump contains data from several nodes.- Specified by:
- onCacheConfigsin interface- DumpConsumer
- Parameters:
- caches- Stored cache data.
 
 - 
onPartitionpublic void onPartition(int grp, int part, Iterator<DumpEntry> data)Handles cache data. This method can be invoked by several threads concurrently. Note, there can be several copies of group partition in the dump. This can happen if dump contains data from several nodes. In this case callback will be invoked several time for the same pair of [grp, part] values.- Specified by:
- onPartitionin interface- DumpConsumer
- Parameters:
- grp- Group id.
- part- Partition.
- data- Cache data iterator.
- See Also:
- DumpReaderConfiguration.threadCount()
 
 - 
stoppublic void stop() Stops the consumer. This method can be invoked only afterDumpConsumer.start().- Specified by:
- stopin interface- DumpConsumer
 
 - 
startpublic void start() Starts the consumer.- Specified by:
- startin interface- DumpConsumer
 
 
- 
 
-