Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 5 additions & 7 deletions pyiceberg/table/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -2072,13 +2072,11 @@ def _build_residual_evaluator(self, spec_id: int) -> Callable[[DataFile], Residu
# The lambda created here is run in multiple threads.
# So we avoid creating _EvaluatorExpression methods bound to a single
# shared instance across multiple threads.
return lambda datafile: (
residual_evaluator_of(
spec=spec,
expr=self.row_filter,
case_sensitive=self.case_sensitive,
schema=self.table_metadata.schema(),
)
return lambda datafile: residual_evaluator_of(
spec=spec,
expr=self.row_filter,
case_sensitive=self.case_sensitive,
schema=self.table_metadata.schema(),
)

@staticmethod
Expand Down
61 changes: 24 additions & 37 deletions vendor/fb303/FacebookService.py
Original file line number Diff line number Diff line change
Expand Up @@ -50,36 +50,31 @@ def getName(self):
Returns a descriptive name of the service

"""
pass

def getVersion(self):
"""
Returns the version of the service

"""
pass

def getStatus(self):
"""
Gets the status of this service

"""
pass

def getStatusDetails(self):
"""
User friendly description of status, such as why the service is in
the dead or warning state, or what is being started or stopped.

"""
pass

def getCounters(self):
"""
Gets the counters for this service

"""
pass

def getCounter(self, key):
"""
Expand All @@ -89,7 +84,6 @@ def getCounter(self, key):
- key

"""
pass

def setOption(self, key, value):
"""
Expand All @@ -100,7 +94,6 @@ def setOption(self, key, value):
- value

"""
pass

def getOption(self, key):
"""
Expand All @@ -110,14 +103,12 @@ def getOption(self, key):
- key

"""
pass

def getOptions(self):
"""
Gets all options

"""
pass

def getCpuProfile(self, profileDurationInSec):
"""
Expand All @@ -128,28 +119,24 @@ def getCpuProfile(self, profileDurationInSec):
- profileDurationInSec

"""
pass

def aliveSince(self):
"""
Returns the unix time that the server has been running since

"""
pass

def reinitialize(self):
"""
Tell the server to reload its configuration, reopen log files, etc

"""
pass

def shutdown(self):
"""
Suggest a shutdown to the server

"""
pass


class Client(Iface):
Expand Down Expand Up @@ -890,7 +877,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -958,7 +945,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1011,7 +998,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1079,7 +1066,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1132,7 +1119,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1198,7 +1185,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1251,7 +1238,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1319,7 +1306,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1372,7 +1359,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1452,7 +1439,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1528,7 +1515,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1603,7 +1590,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1693,7 +1680,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1754,7 +1741,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1822,7 +1809,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1899,7 +1886,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -1952,7 +1939,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2036,7 +2023,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2110,7 +2097,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2187,7 +2174,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2240,7 +2227,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2306,7 +2293,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2359,7 +2346,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down Expand Up @@ -2404,7 +2391,7 @@ def validate(self):
return

def __repr__(self):
L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()]
L = [f"{key}={value!r}" for key, value in self.__dict__.items()]
return "{}({})".format(self.__class__.__name__, ", ".join(L))

def __eq__(self, other):
Expand Down
1 change: 0 additions & 1 deletion vendor/fb303/constants.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,4 +23,3 @@
#



Loading
Loading