Package org.apache.ignite.dump
Interface DumpConsumer
-
- All Known Implementing Classes:
JsonDumpConsumer
public interface DumpConsumer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onCacheConfigs(Iterator<org.apache.ignite.internal.processors.cache.StoredCacheData> caches)
Handles cache configs.void
onMappings(Iterator<TypeMapping> mappings)
Handles type mappings.void
onPartition(int grp, int part, Iterator<DumpEntry> data)
Handles cache data.void
onTypes(Iterator<BinaryType> types)
Handles binary types.void
start()
Starts the consumer.void
stop()
Stops the consumer.
-
-
-
Method Detail
-
start
void start()
Starts the consumer.
-
onMappings
void onMappings(Iterator<TypeMapping> mappings)
Handles type mappings.- Parameters:
mappings
- Mappings iterator.
-
onTypes
void onTypes(Iterator<BinaryType> types)
Handles binary types.- Parameters:
types
- Binary types iterator.
-
onCacheConfigs
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.- Parameters:
caches
- Stored cache data.
-
onPartition
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.- Parameters:
grp
- Group id.part
- Partition.data
- Cache data iterator.- See Also:
DumpReaderConfiguration.threadCount()
-
stop
void stop()
Stops the consumer. This method can be invoked only afterstart()
.
-
-