tag KJT related part to sc.INPUT_DIST (#2678)

Summary:

tag KJT output to sc.INPUT_DIST to enforce placement on CPU

Differential Revision: D67313214

Author: Jiyuan Zhang

torchrec/quant/embedding_modules.py

@@ -300,6 +300,23 @@ def _fx_trec_unwrap_kjt(
         return indices.int(), offsets.int()
 
 
+@torch.fx.wrap
+def _fx_trec_unwrap_jt(
+    jt: JaggedTensor,
+) -> Tuple[torch.Tensor, torch.Tensor]:
+    """
+    Forced conversions to support TBE
+    CPU - int32 or int64, offsets dtype must match
+    GPU - int32 only, offsets dtype must match
+    """
+    indices = jt.values()
+    offsets = jt.offsets()
+    if jt.device().type == "cpu":
+        return indices, offsets.type(dtype=indices.dtype)
+    else:
+        return indices.int(), offsets.int()
+
+
 class EmbeddingBagCollection(EmbeddingBagCollectionInterface, ModuleNoCopyMixin):
     """
     This class represents a reimplemented version of the EmbeddingBagCollection