Review Board 1.7.22


Patch for DRILL-271

Review Request #15111 - Created Oct. 31, 2013 and updated

Steven Phillips
DRILL-271
Reviewers
drill-git
drill-git
DRILL-271 Address code review comments. VectorAccessibleSerializable now take WritableBatch. Release and reconstruct code now part of Writablebatch class.


DRILL-271 abstract out serialization in trace record batch by using VectorAccessibleSerializable. Add ability to retain vectors.


DRILL-271 release buffer in VectorAccessibleSerializable read. Also read directly from stream.


DRILL-271 refactor DistributedCache code. Uses hazel cast 3.1 and custom serialization.


DRILL-271 retool VectorContainerSerializable to work with containers and batches. also modify DrillSerializable to work with InputStream, OutputStream


Addressed review comments from Jacques


DRILL-256 revised patch

 

Diff revision 1

This is not the most recent revision of the diff. The latest diff is revision 2. See what's changed.

1 2
1 2

  1. distribution/src/resources/drill-override.conf: Loading...
  2. exec/java-exec/pom.xml: Loading...
  3. exec/java-exec/src/main/java/org/apache/drill/exec/ExecConstants.java: Loading...
  4. exec/java-exec/src/main/java/org/apache/drill/exec/cache/DrillSerializable.java: Loading...
  5. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCDrillSerializableWrapper.java: Loading...
  6. protocol/src/main/java/org/apache/drill/exec/proto/helper/QueryIdHelper.java: Loading...
  7. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCVectorAccessibleSerializer.java: Loading...
  8. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HazelCache.java: Loading...
  9. exec/java-exec/src/main/java/org/apache/drill/exec/cache/LocalCache.java: Loading...
  10. exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoBufWrap.java: Loading...
  11. exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorAccessibleSerializable.java: Loading...
  12. exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorContainerSerializable.java: Loading...
  13. exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java: Loading...
  14. exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java: Loading...
  15. exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractPhysicalVisitor.java: Loading...
  16. exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/PhysicalVisitor.java: Loading...
  17. exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/Trace.java: Loading...
  18. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ImplCreator.java: Loading...
  19. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/TraceInjector.java: Loading...
  20. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/orderedpartitioner/OrderedPartitionRecordBatch.java: Loading...
This diff has been split across 2 pages: 1 2 >
distribution/src/resources/drill-override.conf
Revision c2ed9df26b63ad81b06aa665af765e67ec930656 New Change
[20] 68 lines
[+20]
69
  work: {
69
  work: {
70
    max.width.per.endpoint: 5,
70
    max.width.per.endpoint: 5,
71
    global.max.width: 100,
71
    global.max.width: 100,
72
    executor.threads: 4
72
    executor.threads: 4
73
  }
73
  }

    
   
74
  trace: {

    
   
75
    directory: "/var/log/drill"

    
   
76
  }
74
}
77
}
exec/java-exec/pom.xml
Revision 063e60e038beb2c3100848985afea9c651af9ca6 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/ExecConstants.java
Revision 72776d1a79cdb58241a9de72cb985462b3579068 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/DrillSerializable.java
Revision 534d78106fd61ab16a428e6d46bced563724fb15 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCDrillSerializableWrapper.java
Revision 3f2c41c5e61fd097a697b6c31a3de20b307d1b50 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCSerializableWrapperClasses.java
Revision d22723ab021259197c8fa4f2cc23270301990de4 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCVectorAccessibleSerializer.java
New File
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/HazelCache.java
Revision 577dfebb1e9108650ea72b00f844748de3de56fb New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/LocalCache.java
Revision 7ad6ec687e02a90e4936bcae16e8ef666818c327 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoBufWrap.java
Revision 4aea645afd278a6b0233eff19487dbd66c6a0272 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorAccessibleSerializable.java
New File
 
exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorContainerSerializable.java
Revision 1e6eeacec76ebd434720849b669735c9cf82df05 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
Revision 160ef7ff21b079cd0e51aa5b62af09c96e932b5f New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java
Revision 352c467a8f26183631f03a89c5cf21c1df18b3ac New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractPhysicalVisitor.java
Revision bf6c68ca2d67d8d40001ee21656345ceb823ae75 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/PhysicalVisitor.java
Revision 5692b9f0827eec39671a29cee064e8247b7d344a New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/Trace.java
New File
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ImplCreator.java
Revision 844b3a750b4fd4bd510b0ada1a4724f127ab6b12 New Change
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/TraceInjector.java
New File
 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/orderedpartitioner/OrderedPartitionRecordBatch.java
Revision 7dc7d559dfbd5af4a607a4ff9a5ff8b0d59c0e93 New Change
 
  1. distribution/src/resources/drill-override.conf: Loading...
  2. exec/java-exec/pom.xml: Loading...
  3. exec/java-exec/src/main/java/org/apache/drill/exec/ExecConstants.java: Loading...
  4. exec/java-exec/src/main/java/org/apache/drill/exec/cache/DrillSerializable.java: Loading...
  5. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCDrillSerializableWrapper.java: Loading...
  6. protocol/src/main/java/org/apache/drill/exec/proto/helper/QueryIdHelper.java: Loading...
  7. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HCVectorAccessibleSerializer.java: Loading...
  8. exec/java-exec/src/main/java/org/apache/drill/exec/cache/HazelCache.java: Loading...
  9. exec/java-exec/src/main/java/org/apache/drill/exec/cache/LocalCache.java: Loading...
  10. exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoBufWrap.java: Loading...
  11. exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorAccessibleSerializable.java: Loading...
  12. exec/java-exec/src/main/java/org/apache/drill/exec/cache/VectorContainerSerializable.java: Loading...
  13. exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java: Loading...
  14. exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java: Loading...
  15. exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractPhysicalVisitor.java: Loading...
  16. exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/PhysicalVisitor.java: Loading...
  17. exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/Trace.java: Loading...
  18. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/ImplCreator.java: Loading...
  19. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/TraceInjector.java: Loading...
  20. exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/orderedpartitioner/OrderedPartitionRecordBatch.java: Loading...
This diff has been split across 2 pages: 1 2 >