MCPcopy Create free account

hub / github.com/Big-Data-Manning/big-data-code / types & classes

Types & classes117 in github.com/Big-Data-Manning/big-data-code

ClassAnalyzeVisits
src/java/manning/speedlayer/TridentSpeedLayer.java:143
ClassAnalyzeVisits
src/java/manning/batchlayer/BatchWorkflow.java:507
ClassBatchWorkflow
The entire batch layer for SuperWebAnalytics.com. This is a purely recomputation based implementation. Additional efficiency can be achieved by adding
src/java/manning/batchlayer/BatchWorkflow.java:70
ClassBidirectionalEdge
src/java/manning/batchlayer/BatchWorkflow.java:570
ClassBooleanToInt
src/java/manning/speedlayer/TridentSpeedLayer.java:237
InterfaceCassandraSerializerFactory
src/java/manning/speedlayer/CassandraState.java:23
ClassCassandraState
src/java/manning/speedlayer/CassandraState.java:22
ClassCombinedCombinerAggregator
src/java/manning/speedlayer/TridentSpeedLayer.java:249
ClassConstructHyperLogLog
src/java/manning/batchlayer/BatchWorkflow.java:428
ClassData
src/java/manning/test/Data.java:6
ClassData
src/java/manning/schema/Data.java:36
ClassDataPailStructure
src/java/manning/tap/DataPailStructure.java:5
ClassDataPailTap
src/java/manning/tap/DataPailTap.java:9
ClassDataPailTapOptions
src/java/manning/tap/DataPailTap.java:10
ClassDataStandardScheme
src/java/manning/schema/Data.java:410
ClassDataStandardSchemeFactory
src/java/manning/schema/Data.java:404
ClassDataTupleScheme
src/java/manning/schema/Data.java:475
ClassDataTupleSchemeFactory
src/java/manning/schema/Data.java:469
ClassDataUnit
src/java/manning/schema/DataUnit.java:36
ClassDebug
src/java/manning/batchlayer/BatchWorkflow.java:277
ClassEdgeStructure
src/java/manning/tap/SplitDataPailStructure.java:38
ClassEdgifyEquiv
src/java/manning/batchlayer/BatchWorkflow.java:561
ClassEmitGranularities
src/java/manning/batchlayer/BatchWorkflow.java:262
ClassEquivEdge
src/java/manning/schema/EquivEdge.java:36
ClassEquivEdgeStandardScheme
src/java/manning/schema/EquivEdge.java:407
ClassEquivEdgeStandardSchemeFactory
src/java/manning/schema/EquivEdge.java:401
ClassEquivEdgeTupleScheme
src/java/manning/schema/EquivEdge.java:472
ClassEquivEdgeTupleSchemeFactory
src/java/manning/schema/EquivEdge.java:466
ClassExternalDataSystem
src/java/manning/schema/ExternalDataSystem.java:36
ClassExternalDataSystemStandardScheme
src/java/manning/schema/ExternalDataSystem.java:232
ClassExternalDataSystemStandardSchemeFactory
src/java/manning/schema/ExternalDataSystem.java:226
ClassExternalDataSystemTupleScheme
src/java/manning/schema/ExternalDataSystem.java:269
ClassExternalDataSystemTupleSchemeFactory
src/java/manning/schema/ExternalDataSystem.java:263
ClassExtractDomain
src/java/manning/speedlayer/TridentSpeedLayer.java:107
ClassExtractDomain
src/java/manning/batchlayer/BatchWorkflow.java:495
ClassExtractFilterBolt
src/java/manning/speedlayer/UniquesOverTime.java:112
ClassExtractPageViewFields
src/java/manning/batchlayer/BatchWorkflow.java:245
ClassFactory
src/java/manning/speedlayer/CassandraState.java:78
InterfaceFieldStructure
src/java/manning/tap/SplitDataPailStructure.java:19
EnumGenderType
src/java/manning/schema/GenderType.java:14
ClassIntegerSerializer
src/java/manning/speedlayer/CassandraState.java:37
ClassIterateEdges
src/java/manning/batchlayer/BatchWorkflow.java:583
ClassLocation
src/java/manning/schema/Location.java:36
ClassLocationStandardScheme
src/java/manning/schema/Location.java:476
ClassLocationStandardSchemeFactory
src/java/manning/schema/Location.java:470
ClassLocationTupleScheme
src/java/manning/schema/Location.java:558
ClassLocationTupleSchemeFactory
src/java/manning/schema/Location.java:552
ClassMakeNormalizedPageview
src/java/manning/batchlayer/BatchWorkflow.java:607
ClassMergeHyperLogLog
src/java/manning/batchlayer/BatchWorkflow.java:445
ClassNormalizeURL
src/java/manning/speedlayer/TridentSpeedLayer.java:37
ClassNormalizeURL
src/java/manning/batchlayer/BatchWorkflow.java:183
ClassOptions
src/java/manning/speedlayer/CassandraState.java:52
ClassOrigSystem
src/java/manning/schema/OrigSystem.java:36
ClassPageID
src/java/manning/schema/PageID.java:36
ClassPageProperty
src/java/manning/schema/PageProperty.java:36
ClassPagePropertyStandardScheme
src/java/manning/schema/PageProperty.java:407
ClassPagePropertyStandardSchemeFactory
src/java/manning/schema/PageProperty.java:401
ClassPagePropertyTupleScheme
src/java/manning/schema/PageProperty.java:472
ClassPagePropertyTupleSchemeFactory
src/java/manning/schema/PageProperty.java:466
ClassPagePropertyValue
src/java/manning/schema/PagePropertyValue.java:36
ClassPageViewEdge
src/java/manning/schema/PageViewEdge.java:36
ClassPageViewEdgeStandardScheme
src/java/manning/schema/PageViewEdge.java:492
ClassPageViewEdgeStandardSchemeFactory
src/java/manning/schema/PageViewEdge.java:486
ClassPageViewEdgeTupleScheme
src/java/manning/schema/PageViewEdge.java:568
ClassPageViewEdgeTupleSchemeFactory
src/java/manning/schema/PageViewEdge.java:562
ClassPageViewSystem
src/java/manning/schema/PageViewSystem.java:36
ClassPageViewSystemStandardScheme
src/java/manning/schema/PageViewSystem.java:232
ClassPageViewSystemStandardSchemeFactory
src/java/manning/schema/PageViewSystem.java:226
ClassPageViewSystemTupleScheme
src/java/manning/schema/PageViewSystem.java:269
ClassPageViewSystemTupleSchemeFactory
src/java/manning/schema/PageViewSystem.java:263
ClassPageviewScheme
src/java/manning/speedlayer/UniquesOverTime.java:83
ClassPedigree
src/java/manning/schema/Pedigree.java:36
ClassPedigreeStandardScheme
src/java/manning/schema/Pedigree.java:504
ClassPedigreeStandardSchemeFactory
src/java/manning/schema/Pedigree.java:498
ClassPedigreeTupleScheme
src/java/manning/schema/Pedigree.java:579
ClassPedigreeTupleSchemeFactory
src/java/manning/schema/Pedigree.java:573
ClassPersonID
src/java/manning/schema/PersonID.java:36
ClassPersonProperty
src/java/manning/schema/PersonProperty.java:36
ClassPersonPropertyStandardScheme
src/java/manning/schema/PersonProperty.java:407
ClassPersonPropertyStandardSchemeFactory
src/java/manning/schema/PersonProperty.java:401
ClassPersonPropertyTupleScheme
src/java/manning/schema/PersonProperty.java:472
ClassPersonPropertyTupleSchemeFactory
src/java/manning/schema/PersonProperty.java:466
ClassPersonPropertyValue
src/java/manning/schema/PersonPropertyValue.java:36
ClassPropertyStructure
src/java/manning/tap/SplitDataPailStructure.java:43
EnumSource
src/java/manning/schema/Source.java:14
ClassSplitDataPailStructure
src/java/manning/tap/SplitDataPailStructure.java:18
ClassSplitDataPailTap
src/java/manning/tap/SplitDataPailTap.java:13
ClassSplitDataPailTapOptions
src/java/manning/tap/SplitDataPailTap.java:14
ClassStringSerializer
src/java/manning/speedlayer/CassandraState.java:27
ClassThriftPailStructure
src/java/manning/tap/ThriftPailStructure.java:11
ClassToHourBucket
src/java/manning/speedlayer/TridentSpeedLayer.java:53
ClassToHourBucket
src/java/manning/batchlayer/BatchWorkflow.java:235
ClassToSerializedLong
src/java/manning/batchlayer/BatchWorkflow.java:321
ClassToSerializedLongPair
src/java/manning/batchlayer/BatchWorkflow.java:398
ClassToSerializedString
src/java/manning/batchlayer/BatchWorkflow.java:384
ClassToUrlBucketedKey
src/java/manning/batchlayer/BatchWorkflow.java:304
ClassTridentSpeedLayer
src/java/manning/speedlayer/TridentSpeedLayer.java:34
ClassUniquesOverTime
src/java/manning/speedlayer/UniquesOverTime.java:52
ClassUpdateCassandraBolt
This is a simple illustrative example, though in reality you'll achieve much greater throughput by batching the bolt as discussed in the book.
src/java/manning/speedlayer/UniquesOverTime.java:142
ClassUrlOnlyScheme
src/java/manning/batchlayer/BatchWorkflow.java:341
next →1–100 of 117, ranked by callers