Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Big-Data-Manning/big-data-code
/ types & classes
Types & classes
117 in github.com/Big-Data-Manning/big-data-code
⨍
Functions
640
◇
Types & classes
117
Class
AnalyzeVisits
src/java/manning/speedlayer/TridentSpeedLayer.java:143
Class
AnalyzeVisits
src/java/manning/batchlayer/BatchWorkflow.java:507
Class
BatchWorkflow
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
Class
BidirectionalEdge
src/java/manning/batchlayer/BatchWorkflow.java:570
Class
BooleanToInt
src/java/manning/speedlayer/TridentSpeedLayer.java:237
Interface
CassandraSerializerFactory
src/java/manning/speedlayer/CassandraState.java:23
Class
CassandraState
src/java/manning/speedlayer/CassandraState.java:22
Class
CombinedCombinerAggregator
src/java/manning/speedlayer/TridentSpeedLayer.java:249
Class
ConstructHyperLogLog
src/java/manning/batchlayer/BatchWorkflow.java:428
Class
Data
src/java/manning/test/Data.java:6
Class
Data
src/java/manning/schema/Data.java:36
Class
DataPailStructure
src/java/manning/tap/DataPailStructure.java:5
Class
DataPailTap
src/java/manning/tap/DataPailTap.java:9
Class
DataPailTapOptions
src/java/manning/tap/DataPailTap.java:10
Class
DataStandardScheme
src/java/manning/schema/Data.java:410
Class
DataStandardSchemeFactory
src/java/manning/schema/Data.java:404
Class
DataTupleScheme
src/java/manning/schema/Data.java:475
Class
DataTupleSchemeFactory
src/java/manning/schema/Data.java:469
Class
DataUnit
src/java/manning/schema/DataUnit.java:36
Class
Debug
src/java/manning/batchlayer/BatchWorkflow.java:277
Class
EdgeStructure
src/java/manning/tap/SplitDataPailStructure.java:38
Class
EdgifyEquiv
src/java/manning/batchlayer/BatchWorkflow.java:561
Class
EmitGranularities
src/java/manning/batchlayer/BatchWorkflow.java:262
Class
EquivEdge
src/java/manning/schema/EquivEdge.java:36
Class
EquivEdgeStandardScheme
src/java/manning/schema/EquivEdge.java:407
Class
EquivEdgeStandardSchemeFactory
src/java/manning/schema/EquivEdge.java:401
Class
EquivEdgeTupleScheme
src/java/manning/schema/EquivEdge.java:472
Class
EquivEdgeTupleSchemeFactory
src/java/manning/schema/EquivEdge.java:466
Class
ExternalDataSystem
src/java/manning/schema/ExternalDataSystem.java:36
Class
ExternalDataSystemStandardScheme
src/java/manning/schema/ExternalDataSystem.java:232
Class
ExternalDataSystemStandardSchemeFactory
src/java/manning/schema/ExternalDataSystem.java:226
Class
ExternalDataSystemTupleScheme
src/java/manning/schema/ExternalDataSystem.java:269
Class
ExternalDataSystemTupleSchemeFactory
src/java/manning/schema/ExternalDataSystem.java:263
Class
ExtractDomain
src/java/manning/speedlayer/TridentSpeedLayer.java:107
Class
ExtractDomain
src/java/manning/batchlayer/BatchWorkflow.java:495
Class
ExtractFilterBolt
src/java/manning/speedlayer/UniquesOverTime.java:112
Class
ExtractPageViewFields
src/java/manning/batchlayer/BatchWorkflow.java:245
Class
Factory
src/java/manning/speedlayer/CassandraState.java:78
Interface
FieldStructure
src/java/manning/tap/SplitDataPailStructure.java:19
Enum
GenderType
src/java/manning/schema/GenderType.java:14
Class
IntegerSerializer
src/java/manning/speedlayer/CassandraState.java:37
Class
IterateEdges
src/java/manning/batchlayer/BatchWorkflow.java:583
Class
Location
src/java/manning/schema/Location.java:36
Class
LocationStandardScheme
src/java/manning/schema/Location.java:476
Class
LocationStandardSchemeFactory
src/java/manning/schema/Location.java:470
Class
LocationTupleScheme
src/java/manning/schema/Location.java:558
Class
LocationTupleSchemeFactory
src/java/manning/schema/Location.java:552
Class
MakeNormalizedPageview
src/java/manning/batchlayer/BatchWorkflow.java:607
Class
MergeHyperLogLog
src/java/manning/batchlayer/BatchWorkflow.java:445
Class
NormalizeURL
src/java/manning/speedlayer/TridentSpeedLayer.java:37
Class
NormalizeURL
src/java/manning/batchlayer/BatchWorkflow.java:183
Class
Options
src/java/manning/speedlayer/CassandraState.java:52
Class
OrigSystem
src/java/manning/schema/OrigSystem.java:36
Class
PageID
src/java/manning/schema/PageID.java:36
Class
PageProperty
src/java/manning/schema/PageProperty.java:36
Class
PagePropertyStandardScheme
src/java/manning/schema/PageProperty.java:407
Class
PagePropertyStandardSchemeFactory
src/java/manning/schema/PageProperty.java:401
Class
PagePropertyTupleScheme
src/java/manning/schema/PageProperty.java:472
Class
PagePropertyTupleSchemeFactory
src/java/manning/schema/PageProperty.java:466
Class
PagePropertyValue
src/java/manning/schema/PagePropertyValue.java:36
Class
PageViewEdge
src/java/manning/schema/PageViewEdge.java:36
Class
PageViewEdgeStandardScheme
src/java/manning/schema/PageViewEdge.java:492
Class
PageViewEdgeStandardSchemeFactory
src/java/manning/schema/PageViewEdge.java:486
Class
PageViewEdgeTupleScheme
src/java/manning/schema/PageViewEdge.java:568
Class
PageViewEdgeTupleSchemeFactory
src/java/manning/schema/PageViewEdge.java:562
Class
PageViewSystem
src/java/manning/schema/PageViewSystem.java:36
Class
PageViewSystemStandardScheme
src/java/manning/schema/PageViewSystem.java:232
Class
PageViewSystemStandardSchemeFactory
src/java/manning/schema/PageViewSystem.java:226
Class
PageViewSystemTupleScheme
src/java/manning/schema/PageViewSystem.java:269
Class
PageViewSystemTupleSchemeFactory
src/java/manning/schema/PageViewSystem.java:263
Class
PageviewScheme
src/java/manning/speedlayer/UniquesOverTime.java:83
Class
Pedigree
src/java/manning/schema/Pedigree.java:36
Class
PedigreeStandardScheme
src/java/manning/schema/Pedigree.java:504
Class
PedigreeStandardSchemeFactory
src/java/manning/schema/Pedigree.java:498
Class
PedigreeTupleScheme
src/java/manning/schema/Pedigree.java:579
Class
PedigreeTupleSchemeFactory
src/java/manning/schema/Pedigree.java:573
Class
PersonID
src/java/manning/schema/PersonID.java:36
Class
PersonProperty
src/java/manning/schema/PersonProperty.java:36
Class
PersonPropertyStandardScheme
src/java/manning/schema/PersonProperty.java:407
Class
PersonPropertyStandardSchemeFactory
src/java/manning/schema/PersonProperty.java:401
Class
PersonPropertyTupleScheme
src/java/manning/schema/PersonProperty.java:472
Class
PersonPropertyTupleSchemeFactory
src/java/manning/schema/PersonProperty.java:466
Class
PersonPropertyValue
src/java/manning/schema/PersonPropertyValue.java:36
Class
PropertyStructure
src/java/manning/tap/SplitDataPailStructure.java:43
Enum
Source
src/java/manning/schema/Source.java:14
Class
SplitDataPailStructure
src/java/manning/tap/SplitDataPailStructure.java:18
Class
SplitDataPailTap
src/java/manning/tap/SplitDataPailTap.java:13
Class
SplitDataPailTapOptions
src/java/manning/tap/SplitDataPailTap.java:14
Class
StringSerializer
src/java/manning/speedlayer/CassandraState.java:27
Class
ThriftPailStructure
src/java/manning/tap/ThriftPailStructure.java:11
Class
ToHourBucket
src/java/manning/speedlayer/TridentSpeedLayer.java:53
Class
ToHourBucket
src/java/manning/batchlayer/BatchWorkflow.java:235
Class
ToSerializedLong
src/java/manning/batchlayer/BatchWorkflow.java:321
Class
ToSerializedLongPair
src/java/manning/batchlayer/BatchWorkflow.java:398
Class
ToSerializedString
src/java/manning/batchlayer/BatchWorkflow.java:384
Class
ToUrlBucketedKey
src/java/manning/batchlayer/BatchWorkflow.java:304
Class
TridentSpeedLayer
src/java/manning/speedlayer/TridentSpeedLayer.java:34
Class
UniquesOverTime
src/java/manning/speedlayer/UniquesOverTime.java:52
Class
UpdateCassandraBolt
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
Class
UrlOnlyScheme
src/java/manning/batchlayer/BatchWorkflow.java:341
next →
1–100 of 117, ranked by callers