Renamed 'kerb' parameter to 'kerb_ticket'

This commit is contained in:
Christopher C. Aycock committed 2016-10-28 10:27:52 -04:00
1 parent f1d63de578
commit c2a4e649c2
4 files changed
+10 -10

No files matched your search

+4 -4
View File
@@ -296,8 +296,8 @@ class HdfsClient::HdfsClientImpl {
if (!config->user.empty()) {
hdfsBuilderSetUserName(builder, config->user.c_str());
}
if (!config->kerb.empty()) {
hdfsBuilderSetKerbTicketCachePath(builder, config->kerb.c_str());
if (!config->kerb_ticket.empty()) {
hdfsBuilderSetKerbTicketCachePath(builder, config->kerb_ticket.c_str());
}
fs_ = hdfsBuilderConnect(builder);
@@ -305,7 +305,7 @@ class HdfsClient::HdfsClientImpl {
namenode_host_ = config->host;
port_ = config->port;
user_ = config->user;
kerb_ = config->kerb;
kerb_ticket_ = config->kerb_ticket;
return Status::OK();
}
@@ -438,7 +438,7 @@ class HdfsClient::HdfsClientImpl {
std::string namenode_host_;
std::string user_;
int port_;
std::string kerb_;
std::string kerb_ticket_;
hdfsFS fs_;
};
+1 -1
View File
@@ -60,7 +60,7 @@ struct HdfsConnectionConfig {
std::string host;
int port;
std::string user;
std::string kerb;
std::string kerb_ticket;
};
class ARROW_EXPORT HdfsClient : public FileSystemClient {
+1 -1
View File
@@ -93,7 +93,7 @@ cdef extern from "arrow/io/hdfs.h" namespace "arrow::io" nogil:
c_string host
int port
c_string user
c_string kerb
c_string kerb_ticket
cdef cppclass HdfsPathInfo:
ObjectType kind;
+4 -4
View File
@@ -313,7 +313,7 @@ cdef class HdfsClient:
raise IOError('HDFS client is closed')
@classmethod
def connect(cls, host="default", port=0, user=None, kerb=None):
def connect(cls, host="default", port=0, user=None, kerb_ticket=None):
"""
Connect to an HDFS cluster. All parameters are optional and should
only be set if the defaults need to be overridden.
@@ -327,7 +327,7 @@ cdef class HdfsClient:
host : NameNode. Set to "default" for fs.defaultFS from core-site.xml.
port : NameNode's port. Set to 0 for default or logical (HA) nodes.
user : Username when connecting to HDFS; None implies login user.
kerb : Path to Kerberos ticket cache.
kerb_ticket : Path to Kerberos ticket cache.
Notes
-----
@@ -347,8 +347,8 @@ cdef class HdfsClient:
conf.port = port
if user is not None:
conf.user = tobytes(user)
if kerb is not None:
conf.kerb = tobytes(kerb)
if kerb_ticket is not None:
conf.kerb_ticket = tobytes(kerb_ticket)
with nogil:
check_status(CHdfsClient.Connect(&conf, &out.client))