Add OrcHiveRecordCursor

gerashegalov · Sep 26, 2014 · fc12dcf · fc12dcf
1 parent b937122
commit fc12dcf
Show file tree

Hide file tree

Showing 8 changed files with 698 additions and 2 deletions.
diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientModule.java b/presto-hive/src/main/java/com/facebook/presto/hive/HiveClientModule.java
@@ -85,6 +85,7 @@ public void configure(Binder binder)
  binder.bind(TypeManager.class).toInstance(typeManager);
 
  Multibinder<HiveRecordCursorProvider> recordCursorProviderBinder = Multibinder.newSetBinder(binder, HiveRecordCursorProvider.class);
+ recordCursorProviderBinder.addBinding().to(OrcRecordCursorProvider.class).in(Scopes.SINGLETON);
  recordCursorProviderBinder.addBinding().to(ColumnarTextHiveRecordCursorProvider.class).in(Scopes.SINGLETON);
  recordCursorProviderBinder.addBinding().to(ColumnarBinaryHiveRecordCursorProvider.class).in(Scopes.SINGLETON);
  recordCursorProviderBinder.addBinding().to(GenericHiveRecordCursorProvider.class).in(Scopes.SINGLETON);

diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/HiveRecordCursorProviders.java b/presto-hive/src/main/java/com/facebook/presto/hive/HiveRecordCursorProviders.java
@@ -24,6 +24,7 @@ private HiveRecordCursorProviders() {}
  public static List<HiveRecordCursorProvider> getDefaultProviders()
  {
  return ImmutableList.of(
+ new OrcRecordCursorProvider(),
  new ColumnarTextHiveRecordCursorProvider(),
  new ColumnarBinaryHiveRecordCursorProvider(),
  new GenericHiveRecordCursorProvider());