Skip to content

Commit 0f26364

Browse files
committed
removal of a unused method
1 parent 7558d9c commit 0f26364

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

src/main/scala/org/apache/spark/sql/hbase/HBaseCatalog.scala

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -129,17 +129,6 @@ private[hbase] class HBaseCatalog(@transient hbaseContext: SQLContext,
129129
admin.createTable(tableDescriptor, splitKeys)
130130
}
131131

132-
def enableCoprocessor(hbaseTableName: TableName): Unit = {
133-
if (deploySuccessfully.get) {
134-
val td = admin.getTableDescriptor(hbaseTableName)
135-
td.addCoprocessor(
136-
"org.apache.spark.sql.hbase.SparkSqlRegionObserver",
137-
null, Coprocessor.PRIORITY_USER, null)
138-
} else {
139-
throw new Exception(s"$hbaseTableName has not been deployed successfully")
140-
}
141-
}
142-
143132
def hasCoprocessor(hbaseTableName: TableName): Boolean = {
144133
val hTableDescriptor = admin.getTableDescriptor(hbaseTableName)
145134
hTableDescriptor.hasCoprocessor("org.apache.spark.sql.hbase.SparkSqlRegionObserver")

0 commit comments

Comments
 (0)