Package io.datarouter.client.mysql.node

Class MysqlReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

java.lang.Object
io.datarouter.storage.node.BaseNode<PK,​D,​F>
io.datarouter.storage.node.type.physical.base.BasePhysicalNode<PK,​D,​F>
io.datarouter.client.mysql.node.MysqlReaderNode<PK,​D,​F>
All Implemented Interfaces:
io.datarouter.storage.node.Node<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader<PK,​D>, io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader.IndexedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader.PhysicalIndexedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader<PK,​D>, io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader.IndexedSortedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader.PhysicalIndexedSortedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader<PK,​D>, io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader.PhysicalSortedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader.SortedMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.IndexedOps<PK,​D>, io.datarouter.storage.node.op.NodeOps<PK,​D>, io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK,​D>, io.datarouter.storage.node.op.raw.read.IndexedStorageReader.IndexedStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.raw.read.IndexedStorageReader.PhysicalIndexedStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.raw.read.MapStorageReader<PK,​D>, io.datarouter.storage.node.op.raw.read.MapStorageReader.MapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.raw.read.MapStorageReader.PhysicalMapStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.raw.read.SortedStorageReader<PK,​D>, io.datarouter.storage.node.op.raw.read.SortedStorageReader.PhysicalSortedStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.op.raw.read.SortedStorageReader.SortedStorageReaderNode<PK,​D,​F>, io.datarouter.storage.node.type.physical.PhysicalNode<PK,​D,​F>, java.lang.Comparable<io.datarouter.storage.node.Node<PK,​D,​F>>
Direct Known Subclasses:
MysqlNode
public class MysqlReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>
extends io.datarouter.storage.node.type.physical.base.BasePhysicalNode<PK,​D,​F>
implements io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader.PhysicalIndexedSortedMapStorageReaderNode<PK,​D,​F>

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader

    io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader.IndexedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.combo.reader.IndexedMapStorageReader.PhysicalIndexedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader

    io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader.IndexedSortedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.combo.reader.IndexedSortedMapStorageReader.PhysicalIndexedSortedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader

    io.datarouter.storage.node.op.raw.read.IndexedStorageReader.IndexedStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.raw.read.IndexedStorageReader.PhysicalIndexedStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.raw.read.MapStorageReader

    io.datarouter.storage.node.op.raw.read.MapStorageReader.MapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.raw.read.MapStorageReader.PhysicalMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader

    io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader.PhysicalSortedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.combo.reader.SortedMapStorageReader.SortedMapStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

    Nested classes/interfaces inherited from interface io.datarouter.storage.node.op.raw.read.SortedStorageReader

    io.datarouter.storage.node.op.raw.read.SortedStorageReader.PhysicalSortedStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>, io.datarouter.storage.node.op.raw.read.SortedStorageReader.SortedStorageReaderNode<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>,​F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​D>>

  • Field Summary

    Fields 
    Modifier and Type Field Description
    static int DEFAULT_ITERATE_BATCH_SIZE  

    Fields inherited from interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader

    OP_getByIndex, OP_getByIndexRange, OP_getFromIndex, OP_getIndexKeyRange, OP_getIndexRange, OP_lookupMultiUnique, OP_lookupUnique, OP_scanByIndex, OP_scanIndex, OP_scanIndexKeys

    Fields inherited from interface io.datarouter.storage.node.op.raw.read.MapStorageReader

    OP_exists, OP_get, OP_getKeys, OP_getMulti

    Fields inherited from interface io.datarouter.storage.node.op.raw.read.SortedStorageReader

    OP_getKeysInRange, OP_getPrefixedRange, OP_getRange, OP_scan, OP_scanKeys, OP_scanKeysMulti, OP_scanMulti

  • Constructor Summary

    Constructors 
    Constructor Description
    MysqlReaderNode​(io.datarouter.storage.node.NodeParams<PK,​D,​F> params, MysqlClientType mysqlClientType, MysqlNodeManager mysqlNodeManager)  

  • Method Summary

    Modifier and Type Method Description
    boolean exists​(PK key, io.datarouter.storage.config.Config config)  
    D get​(PK key, io.datarouter.storage.config.Config config)  
    java.util.List<PK> getKeys​(java.util.Collection<PK> keys, io.datarouter.storage.config.Config config)  
    java.util.List<io.datarouter.storage.node.type.index.ManagedNode<PK,​D,​?,​?,​?>> getManagedNodes()  
    java.util.List<D> getMulti​(java.util.Collection<PK> keys, io.datarouter.storage.config.Config config)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    java.util.List<D>    		 getMultiByIndex​(java.util.Collection<IK> keys, io.datarouter.storage.config.Config config, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    java.util.List<IE>    		 getMultiFromIndex​(java.util.Collection<IK> keys, io.datarouter.storage.config.Config config, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo)  
    java.util.List<D> lookupMultiUnique​(java.util.Collection<? extends io.datarouter.model.key.unique.UniqueKey<PK>> uniqueKeys, io.datarouter.storage.config.Config config)  
    D lookupUnique​(io.datarouter.model.key.unique.UniqueKey<PK> uniqueKey, io.datarouter.storage.config.Config config)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>,​ N extends io.datarouter.storage.node.type.index.ManagedNode<PK,​ D,​ IK,​ IE,​ IF>>
    N    		 registerManaged​(N managedNode)  
    io.datarouter.scanner.Scanner<PK> scanKeysMulti​(java.util.Collection<io.datarouter.util.tuple.Range<PK>> ranges, io.datarouter.storage.config.Config config)  
    io.datarouter.scanner.Scanner<D> scanMulti​(java.util.Collection<io.datarouter.util.tuple.Range<PK>> ranges, io.datarouter.storage.config.Config config)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    io.datarouter.scanner.Scanner<D>    		 scanMultiByIndex​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    io.datarouter.scanner.Scanner<IE>    		 scanMultiIndex​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)  
    <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    io.datarouter.scanner.Scanner<IK>    		 scanMultiIndexKeys​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)  

    Methods inherited from class io.datarouter.storage.node.type.physical.base.BasePhysicalNode

    getChildNodes, getClientId, getClientIds, getClientType, getFieldInfo, getName, getPhysicalNodes, getPhysicalNodesForClient, toString, usesClient

    Methods inherited from class io.datarouter.storage.node.BaseNode

    compareTo

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface java.lang.Comparable

    compareTo

    Methods inherited from interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader

    getMultiByIndex, getMultiFromIndex, lookupMultiUnique, lookupUnique, scanMultiByIndex, scanMultiIndex, scanMultiIndexKeys

    Methods inherited from interface io.datarouter.storage.node.op.raw.read.MapStorageReader

    exists, find, find, get, getKeys, getMulti

    Methods inherited from interface io.datarouter.storage.node.Node

    getChildNodes, getClientIds, getName, getPhysicalNodes, getPhysicalNodesForClient, usesClient

    Methods inherited from interface io.datarouter.storage.node.type.physical.PhysicalNode

    getClientId, getClientType, getFieldInfo

    Methods inherited from interface io.datarouter.storage.node.op.raw.read.SortedStorageReader

    count, scan, scan, scan, scan, scanKeys, scanKeys, scanKeys, scanKeys, scanKeysMulti, scanKeysWithPrefix, scanKeysWithPrefix, scanKeysWithPrefixes, scanKeysWithPrefixes, scanMulti, scanWithPrefix, scanWithPrefix, scanWithPrefixes, scanWithPrefixes

  • Field Details

  • Constructor Details

  • Method Details

    • exists

      public boolean exists​(PK key, io.datarouter.storage.config.Config config)
      Specified by:
      exists in interface io.datarouter.storage.node.op.raw.read.MapStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • get

      public D get​(PK key, io.datarouter.storage.config.Config config)
      Specified by:
      get in interface io.datarouter.storage.node.op.raw.read.MapStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • getMulti

      public java.util.List<D> getMulti​(java.util.Collection<PK> keys, io.datarouter.storage.config.Config config)
      Specified by:
      getMulti in interface io.datarouter.storage.node.op.raw.read.MapStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • getKeys

      public java.util.List<PK> getKeys​(java.util.Collection<PK> keys, io.datarouter.storage.config.Config config)
      Specified by:
      getKeys in interface io.datarouter.storage.node.op.raw.read.MapStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • lookupUnique

      public D lookupUnique​(io.datarouter.model.key.unique.UniqueKey<PK> uniqueKey, io.datarouter.storage.config.Config config)
      Specified by:
      lookupUnique in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • lookupMultiUnique

      public java.util.List<D> lookupMultiUnique​(java.util.Collection<? extends io.datarouter.model.key.unique.UniqueKey<PK>> uniqueKeys, io.datarouter.storage.config.Config config)
      Specified by:
      lookupMultiUnique in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • scanMultiIndex

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> io.datarouter.scanner.Scanner<IE> scanMultiIndex​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)
      Specified by:
      scanMultiIndex in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • scanMultiByIndex

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> io.datarouter.scanner.Scanner<D> scanMultiByIndex​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)
      Specified by:
      scanMultiByIndex in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • scanMultiIndexKeys

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> io.datarouter.scanner.Scanner<IK> scanMultiIndexKeys​(io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo, java.util.Collection<io.datarouter.util.tuple.Range<IK>> ranges, io.datarouter.storage.config.Config config)
      Specified by:
      scanMultiIndexKeys in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • getMultiFromIndex

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> java.util.List<IE> getMultiFromIndex​(java.util.Collection<IK> keys, io.datarouter.storage.config.Config config, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo)
      Specified by:
      getMultiFromIndex in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • getMultiByIndex

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> java.util.List<D> getMultiByIndex​(java.util.Collection<IK> keys, io.datarouter.storage.config.Config config, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> indexEntryFieldInfo)
      Specified by:
      getMultiByIndex in interface io.datarouter.storage.node.op.raw.read.IndexedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • registerManaged

      public <IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>,​ N extends io.datarouter.storage.node.type.index.ManagedNode<PK,​ D,​ IK,​ IE,​ IF>> N registerManaged​(N managedNode)
      Specified by:
      registerManaged in interface io.datarouter.storage.node.op.IndexedOps<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • getManagedNodes

      public java.util.List<io.datarouter.storage.node.type.index.ManagedNode<PK,​D,​?,​?,​?>> getManagedNodes()
      Specified by:
      getManagedNodes in interface io.datarouter.storage.node.op.IndexedOps<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • scanKeysMulti

      public io.datarouter.scanner.Scanner<PK> scanKeysMulti​(java.util.Collection<io.datarouter.util.tuple.Range<PK>> ranges, io.datarouter.storage.config.Config config)
      Specified by:
      scanKeysMulti in interface io.datarouter.storage.node.op.raw.read.SortedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>

    • scanMulti

      public io.datarouter.scanner.Scanner<D> scanMulti​(java.util.Collection<io.datarouter.util.tuple.Range<PK>> ranges, io.datarouter.storage.config.Config config)
      Specified by:
      scanMulti in interface io.datarouter.storage.node.op.raw.read.SortedStorageReader<PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​D extends io.datarouter.model.databean.Databean<PK,​D>>